ThreadQueues

gem "thread_queues"

queue = ThreadQueues::BlockingQueue.new

Thread.new do
  3.times do |count|
    queue.push(count)
  end

  queue.close
end

3.times do |count|
  queue.pop #=> 0|1|2
end

queue.pop #=> EOFError

queue = ThreadQueues::BufferedQueue.new(5)

Thread.new do
  10.times do |count|
    queue.push(count)
  end

  queue.close
end

10.times do |count|
  queue.pop #=> 0|1|2|3|4|5|6|7|8|9
end

queue.pop #=> EOFError

queue = ThreadQueues::BufferedQueue.new(5)
string_buffer = ThreadQueues::StringBuffer.new(queue)

Thread.new do
  queue.push("hel")
  queue.push("lo\n")
  queue.push("my\r\n")
  queue.push("nam")
  queue.push("e\n")
  queue.push("is kasper\n")
  queue.close
end

string_buffer.gets #=> "hello\n"
string_buffer.gets #=> "my\r\n"
string_buffer.gets #=> "name\n"
string_buffer.gets #=> "is kasper\n"

string_buffer.read(6) #=> "hello\n"
string_buffer.read(4) #=> "my\r\n"
string_buffer.read(5) #=> "name\n"
string_buffer.read(10) #=> "is kasper\n"