Contents

# frozen_string_literal: true

export :process

Exceptions = import('./exceptions')

def process(&block)
  watcher = Gyro::Async.new
  thread = Thread.new { run_in_thread(watcher, &block) }
  watcher.await
ensure
  thread.kill if thread.alive?
end

# Runs the given block, passing the result or exception to the given context
# @param ctx [Hash] context
# @return [void]
def run_in_thread(watcher)
  result = yield
  watcher.signal!(result)
rescue Exception => e
  watcher.signal!(e)
end

Version data entries

4 entries across 4 versions & 1 rubygems

Version	Path
polyphony-0.26	lib/polyphony/core/thread.rb
polyphony-0.25	lib/polyphony/core/thread.rb
polyphony-0.24	lib/polyphony/core/thread.rb
polyphony-0.23	lib/polyphony/core/thread.rb