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
297 def initialize
298   super
299   @queue = ::Queue.new
300 end