Class | EventMachine::Queue |
In: |
lib/em/queue.rb
|
Parent: | Object |
A cross thread, reactor scheduled, linear queue.
This class provides a simple "Queue" like abstraction on top of the reactor scheduler. It services two primary purposes:
See examples/ex_queue.rb for a detailed example.
q = EM::Queue.new q.push('one', 'two', 'three') 3.times do q.pop{ |msg| puts(msg) } end
Pop items off the queue, running the block on the reactor thread. The pop will not happen immediately, but at some point in the future, either in the next tick, if the queue has data, or when the queue is populated.