Please sign in to comment.
Add support to ensure consistency in threaded environment
Add a new API call which takes a block to ensure that commands occur on the tube you want in a threaded environment. For example beanstalk.on_tube('foo') do |connection| connection.put 'bar' end This will send a USE and then a PUT surrounded by lock so that another thread can't put on the wrong tube.
- Loading branch information...
Showing with 97 additions and 10 deletions.