Contents

require_relative '../spectre'

Thread.abort_on_exception = true

module Spectre
  module Async
    class << self
      @@threads = {}

      def async name='default', &block
        unless @@threads.key? name
          @@threads[name] = []
        end

        @@threads[name] << Thread.new(&block)
      end

      def await name='default'
        return unless @@threads.key? name

        threads = @@threads[name].map { |x| x.join() }

        @@threads.delete(name)

        threads.map { |x| x.value }
      end
    end

    Spectre.delegate :async, :await, to: self
  end
end

Version data entries

8 entries across 8 versions & 1 rubygems

Version	Path
spectre-core-1.14.6	lib/spectre/async.rb
spectre-core-1.14.5	lib/spectre/async.rb
spectre-core-1.14.4	lib/spectre/async.rb
spectre-core-1.14.3	lib/spectre/async.rb
spectre-core-1.14.2	lib/spectre/async.rb
spectre-core-1.14.1	lib/spectre/async.rb
spectre-core-1.14.0	lib/spectre/async.rb
spectre-core-1.13.0	lib/spectre/async.rb