lib/sneakers/workergroup.rb in sneakers-0.0.5 vs lib/sneakers/workergroup.rb in sneakers-0.0.6
- old
+ new
@@ -24,10 +24,10 @@
# accumulate clients and consumers as well
@workers.each do |worker|
worker.run
end
# end per worker
-
+ #
until @stop_flag.wait_for_set(10.0)
Sneakers.logger.info("Heartbeat: running threads [#{Thread.list.count}]")
# report aggregated stats?
end