Sha256: 6bd751c88129edf9ee948e8fb1852508fdfaecc174695456722853b713c2353a
Contents?: true
Size: 1.02 KB
Versions: 103
Compression:
Stored size: 1.02 KB
Contents
require 'concurrent/synchronization/lockable_object'
module Concurrent
# 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 SafeTaskExecutor < Synchronization::LockableObject
def initialize(task, opts = {})
@task = task
@exception_class = opts.fetch(:rescue_exception, false) ? Exception : StandardError
super() # ensures visibility
end
# @return [Array]
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
end
end
Version data entries
103 entries across 103 versions & 16 rubygems