threadedcollections

Threaded Collections is a package for iterating through collections over multiple threads. With large collections, sometimes it can be more efficient to process a collection in parallel, provided that the collected items don't have a interdependencies, or need to be processed in a specific order.

Usage:

require "threaded_collections"

threadcount = 2 arr = [1, 2, 3, 4, 5, 6, 7, 8, 9, 0] tps = ThreadedCollectionProcessor.new(arr) tps.process(2) { |thread_id, item| puts "Thread #{thread_id} processed item: #{item}" }

I abstracted this pattern from a web services client that posted items from a collection, but each request took a second to process. The remote service had plenty of threads available, so I parallelized the task with this pattern.

THIS IS AN ALPHA RELEASE.

I have no plans to break the interface but I do plan to make two major enhancements:

1. Make it possible to mix this functionality in to the Ruby iterators, so you don't have create the ThreadedCollectionProcessor.
2. Make it work with fibers and processes in addition to threads.

Note: Don't implement the Observer pattern inside the block!

Submit bugs, enhancement requests, and other issues through Lighthouse:

http://peteonrails.lighthouseapp.com/projects/11058-threaded-collections/overview