lib/workers/task_group.rb in workers-0.1.2 vs lib/workers/task_group.rb in workers-0.1.3
- old
+ new
@@ -34,9 +34,11 @@
state!(:initialized)
@state = :running
@run_thread = Thread.current
+ return [] if @tasks.empty?
+
@internal_lock.synchronize do
@tasks.each do |task|
@pool.perform { task.run }
end