vendor/bundle/ruby/1.8/gems/work_queue-1.0.0/lib/work_queue.rb
##
# Stops all worker threads immediately, aborting any ongoing tasks.
#
#  wq = WorkQueue.new(1)
#  wq.enqueue_b { sleep(1) }
#  wq.stop
#
Stops all worker threads immediately, aborting any ongoing tasks.
Stops all worker threads immediately aborting any ongoing tasks .
def stop
    @threads.dup.each { |thread| thread.exit.join }
    @tasks.clear
    self
  end
def stop @threads . dup . each { | thread | thread . exit . join } @tasks . clear self end
Stops all worker threads immediately, aborting any ongoing tasks.
Stops all worker threads immediately aborting any ongoing tasks .