class Concurrent::IndirectImmediateExecutor
An executor service which runs all operations on a new thread, blocking until it completes. Operations are performed in the order they are received and no two operations can be performed simultaneously.
This executor service exists mainly for testing an debugging. When used it immediately runs every ‘#post` operation on a new thread, blocking the current thread until the operation is complete. This is similar to how the ImmediateExecutor
works, but the operation has the full stack of the new thread at its disposal. This can be helpful when the operations will spawn more operations on the same executor and so on - such a situation might overflow the single stack in case of an ImmediateExecutor
, which is inconsistent with how it would behave for a threaded executor.
@note Intended for use primarily in testing and debugging.
Public Class Methods
Source
# File lib/concurrent-ruby/concurrent/executor/indirect_immediate_executor.rb, line 21 def initialize super @internal_executor = SimpleExecutorService.new end
Creates a new executor
Concurrent::ImmediateExecutor::new
Public Instance Methods
Source
# File lib/concurrent-ruby/concurrent/executor/indirect_immediate_executor.rb, line 27 def post(*args, &task) raise ArgumentError.new("no block given") unless block_given? return false unless running? event = Concurrent::Event.new @internal_executor.post do begin task.call(*args) ensure event.set end end event.wait true end
@!macro executor_service_method_post