Class: Concurrent::IndirectImmediateExecutor

Inherits:
ImmediateExecutor
  • Object
show all
Defined in:
lib/concurrent-ruby/concurrent/executor/indirect_immediate_executor.rb

Overview

Note:

Intended for use primarily in testing and debugging.

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.

Instance Method Summary collapse

Constructor Details

#initialize ⇒ IndirectImmediateExecutor

Creates a new executor



21
22
23
24
 
# File 'lib/concurrent-ruby/concurrent/executor/indirect_immediate_executor.rb', line 21

def initialize
  super
  @internal_executor = SimpleExecutorService.new
end

Instance Method Details

#post(*args) { ... } ⇒ Boolean

Submit a task to the executor for asynchronous processing.

Parameters:

  • args (Array) —

    zero or more arguments to be passed to the task

Yields:

  • the asynchronous task to perform

Returns:

  • (Boolean) —

    true if the task is queued, false if the executor is not running

Raises:

  • (ArgumentError) —

    if no task is given



27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
 
# 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