class Sequel::Database::AsyncThreadPool::Proxy

  1. lib/sequel/extensions/async_thread_pool.rb
Superclass: BaseProxy

Default object class for async job/proxy result. This uses a queue for synchronization. The JobProcessor will push a result until the queue, and the code to get the value will pop the result from that queue (and repush the result to handle thread safety).

Methods

Public Class

  1. new

Public Class methods

new()
[show source] 
    # File lib/sequel/extensions/async_thread_pool.rb
304 def initialize
305   super
306   @queue = ::Queue.new
307 end