123456789_123456789_123456789_123456789_123456789_

Class: Concurrent::SafeTaskExecutor

Relationships & Source Files
Super Chains via Extension / Inclusion / Inheritance
Class Chain:
self, Synchronization::LockableObject
Instance Chain:
self, Synchronization::LockableObject
Inherits: Concurrent::Synchronization::LockableObject
Defined in: lib/concurrent-ruby/concurrent/executor/safe_task_executor.rb

Overview

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

Class Method Summary

Instance Method Summary

Synchronization::LockableObject - Inherited

#new_condition

Constructor Details

.new(task, opts = {}) ⇒ SafeTaskExecutor

[ GitHub ] 

  


# 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


  







Instance Method Details



  

    #execute(*args)  ⇒ Array 
  



  

    
  





  


  [ GitHub ]


  

  


# 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