Method: Temporal::ThreadPool#schedule

Defined in:
lib/temporal/thread_pool.rb

#schedule(&block) ⇒ Object



31
32
33
34
35
36
# File 'lib/temporal/thread_pool.rb', line 31

def schedule(&block)
  @mutex.synchronize do
    @available_threads -= 1
    @queue << block
  end
end