Skip to content

Instantly share code, notes, and snippets.

@bscott

bscott/em_queue.rb

Created June 18, 2013 06:06
Show Gist options

  • Select an option

    Learn more about clone URLs
  • Save bscott/5802979 to your computer and use it in GitHub Desktop.

Select an option

Learn more about clone URLs
Save bscott/5802979 to your computer and use it in GitHub Desktop.
Download ZIP
Process Queue via EM
Raw
em_queue.rb
EM.run do
queue = EM::Queue.new
queue_work = Proc.new do |data|
Worker.new.call(data)
EM.next_tick { queue.pop(&queue_work) }
end
queue.pop(&queue_work)
queue.push("here's some data")
end
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment