class Concurrent::SafeTaskExecutor
A simple utility class that executes a callable and returns and array of three elements: success - indicating if the callable has been executed without errors value - filled by the callable result if it has been executed without errors, nil otherwise reason - the error risen by the callable if it has been executed with errors, nil otherwise
Public Class Methods
new(task, opts = {})
click to toggle source
Calls superclass method
# File lib/concurrent-ruby/concurrent/executor/safe_task_executor.rb, line 11 def initialize(task, opts = {}) @task = task @exception_class = opts.fetch(:rescue_exception, false) ? Exception : StandardError super() # ensures visibility end
Public Instance Methods
execute(*args)
click to toggle source
@return [Array]
# File lib/concurrent-ruby/concurrent/executor/safe_task_executor.rb, line 18 def execute(*args) success = true value = reason = nil synchronize do begin value = @task.call(*args) success = true rescue @exception_class => ex reason = ex success = false end end [success, value, reason] end