Method: Sequel::Database::AsyncThreadPool::JobProcessor#initialize

Defined in:
lib/sequel/extensions/async_thread_pool.rb

#initialize(queue) ⇒ JobProcessor

Returns a new instance of JobProcessor.



215
216
217
218
219
220
221
 
# File 'lib/sequel/extensions/async_thread_pool.rb', line 215

def initialize(queue)
  @thread = ::Thread.new do
    while proxy = queue.pop
      proxy.__send__(:__run)
    end
  end
end