wip: Created stub of Executor mixin module.

Author: jdantonio

lib/concurrent/executor/executor.rb

@@ -0,0 +1,47 @@
+module Concurrent
+
+  # An exception class raised when the maximum queue size is reached and the
+  # `overflow_policy` is set to `:abort`.
+  RejectedExecutionError = Class.new(StandardError)
+
+  module Executor
+
+    def running?
+      true
+    end
+
+    def shutdown?
+      false
+    end
+
+    def shutdown
+    end
+
+    def kill
+    end
+
+    def wait_for_termination(timeout)
+    end
+
+    def post(*args, &task)
+    end
+
+    # Submit a task to the thread pool for asynchronous processing.
+    #
+    # @param [Proc] task the asynchronous task to perform
+    #
+    # @return [self] returns itself
+    def <<(task)
+      post(&task)
+      self
+    end
+
+    protected
+
+    def init_executor
+    end
+
+    def execute(*args, &task)
+    end
+  end
+end

lib/concurrent/executor/immediate_executor.rb

@@ -1,15 +1,13 @@
+require_relative 'executor'
+
 module Concurrent
   class ImmediateExecutor
+    include Executor
 
-    def post(*args, &block)
+    def post(*args, &task)
       raise ArgumentError.new('no block given') unless block_given?
-      block.call(*args)
+      task.call(*args)
       return true
     end
-
-    def <<(block)
-      post(&block)
-      self
-    end
   end
 end

lib/concurrent/executor/java_single_thread_executor.rb

@@ -1,9 +1,11 @@
 if RUBY_PLATFORM == 'java'
+  require_relative 'executor'
 
   module Concurrent
 
     # @!macro single_thread_executor
     class JavaSingleThreadExecutor
+      include Executor
 
       # Create a new thread pool.
       #
@@ -67,17 +69,6 @@ def post(*args)
         raise RejectedExecutionError
       end
 
-      # Submit a task to the thread pool for asynchronous processing.
-      #
-      # @param [Proc] task the asynchronous task to perform
-      #
-      # @return [self] returns itself
-      def <<(task)
-        @executor.submit(&task)
-      rescue Java::JavaUtilConcurrent::RejectedExecutionException => ex
-        raise RejectedExecutionError
-      end
-
       # Begin an orderly shutdown. Tasks already in the queue will be executed,
       # but no new tasks will be accepted. Has no additional effect if the
       # thread pool is not running.

lib/concurrent/executor/java_thread_pool_executor.rb

@@ -1,13 +1,11 @@
 if RUBY_PLATFORM == 'java'
+  require_relative 'executor'
 
   module Concurrent
 
-    # An exception class raised when the maximum queue size is reached and the
-    # `overflow_policy` is set to `:abort`.
-    RejectedExecutionError = Class.new(StandardError) unless defined? RejectedExecutionError
-
     # @!macro thread_pool_executor
     class JavaThreadPoolExecutor
+      include Executor
 
       # Default maximum number of threads that will be created in the pool.
       DEFAULT_MAX_POOL_SIZE = java.lang.Integer::MAX_VALUE # 2147483647
@@ -215,17 +213,6 @@ def post(*args)
         raise RejectedExecutionError
       end
 
-      # Submit a task to the thread pool for asynchronous processing.
-      #
-      # @param [Proc] task the asynchronous task to perform
-      #
-      # @return [self] returns itself
-      def <<(task)
-        @executor.submit(&task)
-      rescue Java::JavaUtilConcurrent::RejectedExecutionException => ex
-        raise RejectedExecutionError
-      end
-
       # Begin an orderly shutdown. Tasks already in the queue will be executed,
       # but no new tasks will be accepted. Has no additional effect if the
       # thread pool is not running.

lib/concurrent/executor/per_thread_executor.rb

@@ -1,6 +1,9 @@
+require_relative 'executor'
+
 module Concurrent
 
   class PerThreadExecutor
+    include Executor
 
     def self.post(*args)
       raise ArgumentError.new('no block given') unless block_given?
@@ -11,13 +14,8 @@ def self.post(*args)
       return true
     end
 
-    def post(*args, &block)
-      return PerThreadExecutor.post(*args, &block)
-    end
-
-    def <<(block)
-      PerThreadExecutor.post(&block)
-      return self
+    def post(*args, &task)
+      return PerThreadExecutor.post(*args, &task)
     end
   end
 end

lib/concurrent/executor/ruby_single_thread_executor.rb

@@ -1,11 +1,13 @@
 require 'thread'
 
+require_relative 'executor'
 require 'concurrent/atomic/event'
 
 module Concurrent
 
   # @!macro single_thread_executor
   class RubySingleThreadExecutor
+    include Executor
 
     # Create a new thread pool.
     #
@@ -67,16 +69,6 @@ def post(*args, &task)
       end
     end
 
-    # Submit a task to the thread pool for asynchronous processing.
-    #
-    # @param [Proc] task the asynchronous task to perform
-    #
-    # @return [self] returns itself
-    def <<(task)
-      self.post(&task)
-      return self
-    end
-
     # Begin an orderly shutdown. Tasks already in the queue will be executed,
     # but no new tasks will be accepted. Has no additional effect if the
     # thread pool is not running.

lib/concurrent/executor/ruby_thread_pool_executor.rb

@@ -1,16 +1,14 @@
 require 'thread'
 
+require_relative 'executor'
 require 'concurrent/atomic/event'
 require 'concurrent/executor/ruby_thread_pool_worker'
 
 module Concurrent
 
-  # An exception class raised when the maximum queue size is reached and the
-  # `overflow_policy` is set to `:abort`.
-  RejectedExecutionError = Class.new(StandardError) unless defined? RejectedExecutionError
-
   # @!macro thread_pool_executor
   class RubyThreadPoolExecutor
+    include Executor
 
     # Default maximum number of threads that will be created in the pool.
     DEFAULT_MAX_POOL_SIZE = 2**15 # 32768
@@ -188,16 +186,6 @@ def post(*args, &task)
       end
     end
 
-    # Submit a task to the thread pool for asynchronous processing.
-    #
-    # @param [Proc] task the asynchronous task to perform
-    #
-    # @return [self] returns itself
-    def <<(task)
-      self.post(&task)
-      return self
-    end
-
     # Begin an orderly shutdown. Tasks already in the queue will be executed,
     # but no new tasks will be accepted. Has no additional effect if the
     # thread pool is not running.

lib/concurrent/executor/timer_set.rb

@@ -1,4 +1,5 @@
 require 'thread'
+require_relative 'executor'
 require 'concurrent/options_parser'
 require 'concurrent/atomic/event'
 require 'concurrent/collection/priority_queue'
@@ -9,6 +10,7 @@ module Concurrent
   # monitors the set and schedules each task for execution at the appropriate
   # time. Tasks are run on the global task pool or on the supplied executor.
   class TimerSet
+    include Executor
     include OptionsParser
 
     # Create a new set of timed tasks.