concurrent_executor.rb

module ConcurrentExecutor
  class Error < StandardError
    def initialize(exceptions)
      @exceptions = exceptions
      super
    end

    def message
      @exceptions.map { | e | e.message }.join "\n"
    end

    def backtrace
      trace = @exceptions.map { |e| e.backtrace }.join("\n")
      "ConcurrentExecutor::Error START\n #{trace} \nEND \n"
    end
  end

  class Promise
    def initialize(pool: nil)
      @pool = pool || Concurrent::FixedThreadPool.new(20)
      @exceptions = Concurrent::Array.new
    end

    # Sample Usage
    # executor = ConcurrentExecutor::Promise.new(pool: pool)
    # executor.execute(carriers) do | carrier |
    #   ...
    # end
    #
    # values = executor.resolve

    def execute array, &block
      @futures = array.map do | element |
        Concurrent::Promise.execute({ executor: @pool }) do
          yield(element)
        end.rescue do | exception |
          @exceptions << exception
        end
      end

      self
    end

    def resolve
      values = @futures.map(&:value)

      if @exceptions.length > 0
        raise ConcurrentExecutor::Error.new(@exceptions)
      end

      values
    end
  end
end

usage.rb

executor = ConcurrentExecutor::Promise.new.execute(carriers) do |carrier|
# ...
end
 
values = []

begin 
  values = executor.resolve
rescue ConcurrentExecutor::Error => e
  raise e
end