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
Source
# 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
Calls superclass method
Public Instance Methods
Source
# File lib/concurrent-ruby/concurrent/executor/safe_task_executor.rb, line 18 def execute(*args) synchronize do success = false value = reason = nil begin value = @task.call(*args) success = true rescue @exception_class => ex reason = ex success = false end [success, value, reason] end end
@return [Array]