Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- def handle_job job
- test = Proc.new do
- puts "Im a thread and i am handling #{job}"
- end
- unless @workers.include? job[:id]
- @workers[job[:id]] = Thread.new(&test)
- end
- end
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement