Module: IronChef::AsyncEnumerable
- Defined in:
- lib/iron_chef/async_enumerable.rb
Instance Method Summary collapse
Instance Method Details
#each(&block) ⇒ Object
3 4 5 6 7 8 9 |
# File 'lib/iron_chef/async_enumerable.rb', line 3 def each(&block) pool = IronChef::ThreadPool.new(IronChef::Util.thread_pool_size) super do |item| pool.schedule(item, &block) end pool.shutdown end |
#map(&block) ⇒ Object
11 12 13 14 15 16 17 |
# File 'lib/iron_chef/async_enumerable.rb', line 11 def map(&block) pool = IronChef::ThreadPool.new(IronChef::Util.thread_pool_size) super do |item| pool.schedule(item, &block) end pool.shutdown end |