Gecko [ lorencats.com ]

Name	Size	Permission
abstract_executor_service.rb	3.29 KB	-rw-r--r--
cached_thread_pool.rb	2.58 KB	-rw-r--r--
executor_service.rb	5.65 KB	-rw-r--r--
fixed_thread_pool.rb	9.57 KB	-rw-r--r--
immediate_executor.rb	1.8 KB	-rw-r--r--
indirect_immediate_executor.rb	1.54 KB	-rw-r--r--
java_executor_service.rb	2.5 KB	-rw-r--r--
java_single_thread_executor.rb	919 B	-rw-r--r--
java_thread_pool_executor.rb	3.99 KB	-rw-r--r--
ruby_executor_service.rb	1.49 KB	-rw-r--r--
ruby_single_thread_executor.rb	607 B	-rw-r--r--
ruby_thread_pool_executor.rb	9.98 KB	-rw-r--r--
safe_task_executor.rb	1.01 KB	-rw-r--r--
serial_executor_service.rb	991 B	-rw-r--r--
serialized_execution.rb	2.73 KB	-rw-r--r--
serialized_execution_delegator...	859 B	-rw-r--r--
simple_executor_service.rb	2.57 KB	-rw-r--r--
single_thread_executor.rb	2.47 KB	-rw-r--r--
thread_pool_executor.rb	4.19 KB	-rw-r--r--
timer_set.rb	5.92 KB	-rw-r--r--

Code Editor : simple_executor_service.rb

require 'concurrent/atomics'
require 'concurrent/executor/executor_service'

module Concurrent

# An executor service in which every operation spawns a new,
  # independently operating thread.
  #
  # This is perhaps the most inefficient executor service in this
  # library. It exists mainly for testing an debugging. Thread creation
  # and management is expensive in Ruby and this executor performs no
  # resource pooling. This can be very beneficial during testing and
  # debugging because it decouples the using code from the underlying
  # executor implementation. In production this executor will likely
  # lead to suboptimal performance.
  #
  # @note Intended for use primarily in testing and debugging.
  class SimpleExecutorService < RubyExecutorService

# @!macro executor_service_method_post
    def self.post(*args)
      raise ArgumentError.new('no block given') unless block_given?
      Thread.new(*args) do
        Thread.current.abort_on_exception = false
        yield(*args)
      end
      true
    end

# @!macro executor_service_method_left_shift
    def self.<<(task)
      post(&task)
      self
    end

# @!macro executor_service_method_post
    def post(*args, &task)
      raise ArgumentError.new('no block given') unless block_given?
      return false unless running?
      @count.increment
      Thread.new(*args) do
        Thread.current.abort_on_exception = false
        begin
          yield(*args)
        ensure
          @count.decrement
          @stopped.set if @running.false? && @count.value == 0
        end
      end
    end

# @!macro executor_service_method_left_shift
    def <<(task)
      post(&task)
      self
    end

# @!macro executor_service_method_running_question
    def running?
      @running.true?
    end

# @!macro executor_service_method_shuttingdown_question
    def shuttingdown?
      @running.false? && ! @stopped.set?
    end

# @!macro executor_service_method_shutdown_question
    def shutdown?
      @stopped.set?
    end

# @!macro executor_service_method_shutdown
    def shutdown
      @running.make_false
      @stopped.set if @count.value == 0
      true
    end

# @!macro executor_service_method_kill
    def kill
      @running.make_false
      @stopped.set
      true
    end

# @!macro executor_service_method_wait_for_termination
    def wait_for_termination(timeout = nil)
      @stopped.wait(timeout)
    end

private

def ns_initialize
      @running = Concurrent::AtomicBoolean.new(true)
      @stopped = Concurrent::Event.new
      @count = Concurrent::AtomicFixnum.new(0)
    end
  end
end

${this.title}

Code Editor : simple_executor_service.rb