lib/polyphony/core/thread_pool.rb
# Runs the given block on an available thread from the pool.
#
# @param &block [Proc] given block
# @return [any] return value of block
Runs the given block on an available thread from the pool.
Runs the given block on an available thread from the pool .
def process(&block)
      setup unless @task_queue
      watcher = Fiber.current.auto_watcher
      @task_queue << [block, watcher]
      watcher.await
    end
def process ( & block ) setup unless @task_queue watcher = Fiber . current . auto_watcher @task_queue << [ block , watcher ] watcher . await end
Runs the given block on an available thread from the pool.
Runs the given block on an available thread from the pool .
return value of block
return value of block
any
block
<not_specific>
&block
<not_specific>
None