class Concurrent::SimpleExecutorService
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.
Public Class Methods
@!macro executor_service_method_left_shift
# File lib/concurrent-ruby/concurrent/executor/simple_executor_service.rb, line 31 def self.<<(task) post(&task) self end
@!macro executor_service_method_post
# File lib/concurrent-ruby/concurrent/executor/simple_executor_service.rb, line 21 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
Public Instance Methods
@!macro executor_service_method_left_shift
# File lib/concurrent-ruby/concurrent/executor/simple_executor_service.rb, line 53 def <<(task) post(&task) self end
@!macro executor_service_method_kill
# File lib/concurrent-ruby/concurrent/executor/simple_executor_service.rb, line 81 def kill @running.make_false @stopped.set true end
@!macro executor_service_method_post
# File lib/concurrent-ruby/concurrent/executor/simple_executor_service.rb, line 37 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_running_question
# File lib/concurrent-ruby/concurrent/executor/simple_executor_service.rb, line 59 def running? @running.true? end
@!macro executor_service_method_shutdown
# File lib/concurrent-ruby/concurrent/executor/simple_executor_service.rb, line 74 def shutdown @running.make_false @stopped.set if @count.value == 0 true end
@!macro executor_service_method_shutdown_question
# File lib/concurrent-ruby/concurrent/executor/simple_executor_service.rb, line 69 def shutdown? @stopped.set? end
@!macro executor_service_method_shuttingdown_question
# File lib/concurrent-ruby/concurrent/executor/simple_executor_service.rb, line 64 def shuttingdown? @running.false? && ! @stopped.set? end
@!macro executor_service_method_wait_for_termination
# File lib/concurrent-ruby/concurrent/executor/simple_executor_service.rb, line 88 def wait_for_termination(timeout = nil) @stopped.wait(timeout) end
Private Instance Methods
# File lib/concurrent-ruby/concurrent/executor/simple_executor_service.rb, line 94 def ns_initialize(*args) @running = Concurrent::AtomicBoolean.new(true) @stopped = Concurrent::Event.new @count = Concurrent::AtomicFixnum.new(0) end