lib/asir/thread_pool.rb in asir-1.1.8 vs lib/asir/thread_pool.rb in asir-1.1.9
- old
+ new
@@ -5,10 +5,11 @@
module ASIR
class ThreadPool
include Initialization, AdditionalData
attr_accessor :thread_class, :workers, :n_workers
+ attr_accessor :auto_start_workers
attr_accessor :work_queue
attr_accessor :verbose
attr_accessor :run
def initialize *args
@@ -131,10 +132,10 @@
end
def join *args
until @workers.empty?
@workers.each do | worker |
- worker.join(*args)
+ worker && worker.join(*args)
end
end
end
class Work