The Perl Toolchain Summit needs more sponsors. If your company depends on Perl, please support this very important event.
 / 
Thread-Workers-0.06
River stage zero No dependents
++

Changes for version 0.06 - 2012-09-05

  • Removed semaphore to control worker count, seems pointless if every ++ on count I ->up() the semaphore.
  • Removed Stop (!!!!) for boss and workers.
  • Replaced stop_boss/worker with pause_boss and pause_worker. Threads don't die. They just go to sleep.
  • *New method* Thread::Workers::set_drain_cb(\&method_deals_with_drained_queue);
    • You may not want to lose your queue. You can set a sig INT/KILL hook.
    • Thread::Workers::drain() will stop the boss and workers if not stopped, and drain the queue, and feed the data to the callback you set with set_drain_cb.
    • drain() is the preferred way to kill all the threads, it does things in the right order to drain the log and queue.
  • Fixed a bug where workers weren't reading in the right wakeup value, but it worked on accident. Now It Works for the right reason. ;)
  • Removed _tid var, implicit in _thread key
  • Fixed not locking _worker_cmd when stopping workers (same on boss_cmd)
  • Added in locking to all *reads* of _worker_cmd also. Read someplace this was necessary on older perls.
  • Even more POD fixes (I'll get POD to work right one day!)
  • In a sleep state, workers change their interval to 1 sec. After waking, they go back to normal.
  • Same for the boss on sleep state interval changes

Modules

Thread::Workers
Creates a boss which feeds a queue consumed by workers.

Other files