Created SerializedExecutionDelegator to wrap SerializedExecution.

Author: jdantonio

lib/concurrent/executor/serialized_execution.rb

@@ -1,3 +1,5 @@
+require 'delegate'
+require 'concurrent/executor/executor'
 require 'concurrent/logging'
 
 module Concurrent
@@ -85,6 +87,27 @@ def work(job)
 
       call_job job if job
     end
+  end
+
+  # A wrapper/delegator for any `Executor` or `ExecutorService` that
+  # guarantees serialized execution of tasks.
+  #
+  # @see [SimpleDelegator](http://www.ruby-doc.org/stdlib-2.1.2/libdoc/delegate/rdoc/SimpleDelegator.html)
+  # @see Concurrent::SerializedExecution
+  class SerializedExecutionDelegator < SimpleDelegator
+    include SerialExecutor
 
+    def initialize(executor)
+      @executor = executor
+      @serializer = SerializedExecution.new
+      super(executor)
+    end
+
+    # @!macro executor_method_post
+    def post(*args, &task)
+      raise ArgumentError.new('no block given') unless block_given?
+      return false unless running?
+      @serializer.post(@executor, *args, &task)
+    end
   end
 end

spec/concurrent/executor/serialized_execution_spec.rb

@@ -0,0 +1,12 @@
+require 'spec_helper'
+require_relative 'thread_pool_shared'
+
+module Concurrent
+
+  describe SerializedExecutionDelegator do
+
+    subject { SerializedExecutionDelegator.new(ImmediateExecutor.new) }
+
+    it_should_behave_like :executor_service
+  end
+end