Contents

#!/usr/bin/env ruby

$LOAD_PATH.push File.expand_path("../../lib", __FILE__)
require "celluloid/autostart"

module Enumerable
  # Simple parallel map using Celluloid::Futures
  def pmap(&block)
    futures = map { |elem| Celluloid::Future.new(elem, &block) }
    futures.map(&:value)
  end
end

p 100.times.pmap { |n| n * 2 }

Version data entries

8 entries across 8 versions & 1 rubygems

Version	Path
celluloid-0.17.4	examples/simple_pmap.rb
celluloid-0.18.0.pre	examples/simple_pmap.rb
celluloid-0.17.3	examples/simple_pmap.rb
celluloid-0.17.2	examples/simple_pmap.rb
celluloid-0.17.1.2	examples/simple_pmap.rb
celluloid-0.17.1.1	examples/simple_pmap.rb
celluloid-0.17.1	examples/simple_pmap.rb
celluloid-0.17.0	examples/simple_pmap.rb