Merge e7e4532 into 6d72331

examples/pool.rb

@@ -0,0 +1,32 @@
+#!/usr/bin/env ruby
+
+$LOAD_PATH.push File.expand_path("../lib", __dir__)
+require "celluloid/autostart"
+
+# This is required for pool to work as Celluloid doesn't load it by default
+require "celluloid/pool"
+require "prime"
+
+class PrimeWorker
+  include Celluloid
+
+  # Checks if a number is prime
+  def prime(number)
+    if Prime.prime?(number)
+      puts number
+    end
+  end
+end
+
+# Creates a pool of actors that is equal to the number of CPU cores present on
+# the machine
+pool = PrimeWorker.pool
+
+(2..1000).to_a.map do |i|
+  # Asynchronously calls prime method. Celluloid decides which actor to invoke
+  # out of the pool
+  pool.async.prime i
+end
+
+# Keeps the main thread alive for long enough for our output to be displayed
+sleep 100

lib/celluloid.rb

@@ -245,6 +245,10 @@ def behavior_options
     def ===(other)
       other.is_a? self
     end
+
+    def pool
+      raise NoMethodError, "Missing require for \"celluloid/pool\". Add 'require \"celluloid/pool\" for expected behavior."
+    end
   end
 
   # These are methods we don't want added to the Celluloid singleton but to be
@@ -488,11 +492,11 @@ def future(meth = nil, *args, &block)
 
 require "celluloid/group"
 require "celluloid/group/spawner"
-require "celluloid/group/pool"      # TODO: Find way to only load this if being used.
+require "celluloid/group/pool"
 
 require "celluloid/task"
 require "celluloid/task/fibered"
-require "celluloid/task/threaded"   # TODO: Find way to only load this if being used.
+require "celluloid/task/threaded"         # TODO: Find way to only load this if being used.
 
 require "celluloid/actor"
 require "celluloid/cell"