Class: Concurrent::IndirectImmediateExecutor
- Inherits:
-
ImmediateExecutor
- Object
- Synchronization::LockableObject
- AbstractExecutorService
- ImmediateExecutor
- Concurrent::IndirectImmediateExecutor
- Defined in:
- lib/rubypitaya/app-template/vendor/bundle/ruby/3.1.0/gems/concurrent-ruby-1.1.10/lib/concurrent-ruby/concurrent/executor/indirect_immediate_executor.rb
Overview
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.
Constant Summary
Constants inherited from AbstractExecutorService
AbstractExecutorService::FALLBACK_POLICIES
Instance Method Summary collapse
-
#initialize ⇒ IndirectImmediateExecutor
constructor
Creates a new executor.
-
#post(*args) { ... } ⇒ Boolean
Submit a task to the executor for asynchronous processing.
Methods inherited from ImmediateExecutor
#<<, #running?, #shutdown, #shutdown?, #shuttingdown?, #wait_for_termination
Constructor Details
#initialize ⇒ IndirectImmediateExecutor
Creates a new executor
21 22 23 24 |
# File 'lib/rubypitaya/app-template/vendor/bundle/ruby/3.1.0/gems/concurrent-ruby-1.1.10/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.
27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 |
# File 'lib/rubypitaya/app-template/vendor/bundle/ruby/3.1.0/gems/concurrent-ruby-1.1.10/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 |