File tree Expand file tree Collapse file tree 3 files changed +4
-4
lines changed Expand file tree Collapse file tree 3 files changed +4
-4
lines changed Original file line number Diff line number Diff line change 3636require 'concurrent/channel/channel'
3737require 'concurrent/channel/unbuffered_channel'
3838require 'concurrent/channel/buffered_channel'
39- require 'concurrent/channel/ring_buffer '
39+ require 'concurrent/channel/blocking_ring_buffer '
4040
4141require 'concurrent/cached_thread_pool'
4242require 'concurrent/fixed_thread_pool'
Original file line number Diff line number Diff line change 11module Concurrent
2- class RingBuffer
2+ class BlockingRingBuffer
33
44 def initialize ( capacity )
55 @buffer = Array . new ( capacity )
Original file line number Diff line number Diff line change 22
33module Concurrent
44
5- describe RingBuffer do
5+ describe BlockingRingBuffer do
66
77 let ( :capacity ) { 3 }
8- let ( :buffer ) { RingBuffer . new ( capacity ) }
8+ let ( :buffer ) { BlockingRingBuffer . new ( capacity ) }
99
1010 def fill_buffer
1111 capacity . times { buffer . put 3 }
You can’t perform that action at this time.
0 commit comments