public
Fork of benb/executor
Description: Trivially small thread pool implementation for Ruby
Homepage:
Clone URL: git://github.com/jthopple/babypool.git
jthopple (author)
Fri Oct 16 10:16:07 -0700 2009
commit  0c1df66346973361b3d952fc26d2929fa000d2b2
tree    687c4c10de5216fe4883df786a156238799dbe6e
parent  2f6d4263734e90b0703e39c6b5108ec3dcf4a9cd
name age message
file .gitignore Loading commit data...
file LICENCE
file README.rdoc
file babypool.gemspec
directory lib/
file test.rb
README.rdoc

Baby Pool — Simple thread pool for Ruby.

Baby Pool is a simple, but solid implementation of a thread pool using Ruby green threads. Pools are initialized with a thread count and an execution limit. Baby Pool creates an array or workers each in their own thread that listen for incoming jobs.

The pool will continue to accept work until it is drained by calling the drain method.

A quick example:

  • Initialize the pool with a thread count and an execution limit. Each thread’s worker will timeout it’s current job when it reaches the pool’s execution limit.
          pool = BabyPool.new(:thread_count => 10, :execution_limit => 20)
    
  • Give the pool 20 jobs to do.
          (0..20).each do |job|
            pool.work(job) do
              puts "Running job #{job}."
            end
          end
    
  • When you are done, shut down the pool by calling the drain method
          pool.drain