#712

Committed 24 Apr 2014 12:31AM UTC coverage: 77.896% (-19.9%) from 97.805%

Build # #712

Build Type

push

Committed by

Commit Message

Attempting to fix a brittle test of Concurrent::timer.

Coverage Stats

1903 of 2443 relevant lines covered (77.9%)

541.94 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

35.71

/lib/concurrent/collection/ring_buffer.rb

module Concurrent

  # non-thread safe buffer
  class RingBuffer

    def initialize(capacity)
      @buffer = Array.new(capacity)
      @first = @last = 0
      @count = 0
    end


    # @return [Integer] the capacity of the buffer
    def capacity
      @buffer.size
    end

    # @return [Integer] the number of elements currently in the buffer
    def count
      @count
    end

    # @return [Boolean] true if buffer is empty, false otherwise
    def empty?
      @count == 0
    end

    # @return [Boolean] true if buffer is full, false otherwise
    def full?
      @count == capacity
    end

    # @param [Object] value
    # @return [Boolean] true if value has been inserted, false otherwise
    def offer(value)
      return false if full?

      @buffer[@last] = value
      @last = (@last + 1) % @buffer.size
      @count += 1
      true
    end

    # @return [Object] the first available value and removes it from the buffer. If buffer is empty returns nil
    def poll
      result = @buffer[@first]
      @buffer[@first] = nil
      @first = (@first + 1) % @buffer.size
      @count -= 1
      result
    end

    # @return [Object] the first available value and without removing it from the buffer. If buffer is empty returns nil
    def peek
      @buffer[@first]
    end

  end
end

1	module Concurrent	1✔
2
3	# non-thread safe buffer
4	class RingBuffer	1✔
5
6	def initialize(capacity)	1✔
7	@buffer = Array.new(capacity)	×
8	@first = @last = 0	×
9	@count = 0	×
10	end
11
12
13	# @return [Integer] the capacity of the buffer
14	def capacity	1✔
15	@buffer.size	×
16	end
17
18	# @return [Integer] the number of elements currently in the buffer
19	def count	1✔
20	@count	×
21	end
22
23	# @return [Boolean] true if buffer is empty, false otherwise
24	def empty?	1✔
25	@count == 0	×
26	end
27
28	# @return [Boolean] true if buffer is full, false otherwise
29	def full?	1✔
30	@count == capacity	×
31	end
32
33	# @param [Object] value
34	# @return [Boolean] true if value has been inserted, false otherwise
35	def offer(value)	1✔
36	return false if full?	×
37
38	@buffer[@last] = value	×
39	@last = (@last + 1) % @buffer.size	×
40	@count += 1	×
41	true	×
42	end
43
44	# @return [Object] the first available value and removes it from the buffer. If buffer is empty returns nil
45	def poll	1✔
46	result = @buffer[@first]	×
47	@buffer[@first] = nil	×
48	@first = (@first + 1) % @buffer.size	×
49	@count -= 1	×
50	result	×
51	end
52
53	# @return [Object] the first available value and without removing it from the buffer. If buffer is empty returns nil
54	def peek	1✔
55	@buffer[@first]	×
56	end
57
58	end
59	end

jdantonio / concurrent-ruby / #712

Source File Press 'n' to go to next uncovered line, 'b' for previous

Source File
Press 'n' to go to next uncovered line, 'b' for previous