Contents

#!/usr/bin/env ruby

$LOAD_PATH.push File.expand_path("../lib", __dir__)
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

2 entries across 2 versions & 1 rubygems

Version	Path
celluloid-0.18.0	examples/simple_pmap.rb
celluloid-0.18.0.pre2	examples/simple_pmap.rb