lib/rocket_job/worker_pool.rb in rocketjob-5.3.1 vs lib/rocket_job/worker_pool.rb in rocketjob-5.3.2
- old
+ new
@@ -59,9 +59,10 @@
end
# Kill Worker threads
def kill
workers.each(&:kill)
+ workers.clear
end
# Wait for all workers to stop.
# Return [true] if all workers stopped
# Return [false] on timeout