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