Async now gives each object its own thread.

Author: jdantonio

CHANGELOG.md

@@ -1,6 +1,10 @@
 ### Upcoming Release v1.0.0.pre2 (TBD)
 
 * Simplification of `RubySingleThreadExecutor`
+* `Async` improvements
+  - Each object uses its own `SingleThreadExecutor` instead of the global thread pool.
+  - No longers supports executor injection
+  - Much better documentation
 
 ## Current Release v1.0.0.pre1 (19 Aug 2015)
 

README.md

@@ -61,7 +61,7 @@ This library contains a variety of concurrency abstractions at high and low leve
 
 #### General-purpose Concurrency Abstractions
 
-* [Async](http://ruby-concurrency.github.io/concurrent-ruby/Concurrent/Async.html): A mixin module that provides simple asynchronous behavior to any standard class/object or object.
+* [Async](http://ruby-concurrency.github.io/concurrent-ruby/Concurrent/Async.html): A mixin module that provides simple asynchronous behavior to a class. Loosely based on Erlang's [gen_server](http://www.erlang.org/doc/man/gen_server.html).
 * [Future](http://ruby-concurrency.github.io/concurrent-ruby/Concurrent/Future.html): An asynchronous operation that produces a value.
   * [Dataflow](http://ruby-concurrency.github.io/concurrent-ruby/Concurrent.html#dataflow-class_method): Built on Futures, Dataflow allows you to create a task that will be scheduled when all of its data dependencies are available.
 * [Promise](http://ruby-concurrency.github.io/concurrent-ruby/Concurrent/Promise.html): Similar to Futures, with more features.

examples/benchmark_async.rb

@@ -0,0 +1,57 @@
+#!/usr/bin/env ruby
+
+$: << File.expand_path('../../lib', __FILE__)
+
+require 'benchmark'
+require 'benchmark/ips'
+
+require 'concurrent'
+require 'celluloid'
+
+class CelluloidClass
+  include Celluloid
+  def foo
+  end
+  def bar(latch)
+    latch.count_down
+  end
+end
+
+class AsyncClass
+  include Concurrent::Async
+  def foo
+  end
+  def bar(latch)
+    latch.count_down
+  end
+end
+
+IPS_NUM = 100
+BMBM_NUM = 100_000
+
+Benchmark.ips do |bm|
+  latch = Concurrent::CountDownLatch.new(1)
+  celluloid = CelluloidClass.new
+  bm.report('celluloid') do
+    IPS_NUM.times { celluloid.async.foo }
+    celluloid.bar(latch)
+    latch.wait
+  end
+
+  async = AsyncClass.new
+  latch = Concurrent::CountDownLatch.new(1)
+  bm.report('async') do
+    IPS_NUM.times { async.async.foo }
+    async.bar(latch)
+    latch.wait
+  end
+
+  bm.compare!
+end
+
+#Benchmark.bmbm do |bm|
+  #bm.report('celluloid') do
+  #end
+  #bm.report('async') do
+  #end
+#end