Class: Sequel::Database::AsyncThreadPool::Proxy

Inherits:
BaseProxy show all
Defined in:
lib/sequel/extensions/async_thread_pool.rb

Overview

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).

Instance Method Summary collapse

Methods inherited from BaseProxy

#__value, #method_missing, #respond_to_missing?

Methods inherited from BasicObject

const_missing

Constructor Details

#initialize ⇒ Proxy

Returns a new instance of Proxy.



304
305
306
307
 
# File 'lib/sequel/extensions/async_thread_pool.rb', line 304

def initialize
  super
  @queue = ::Queue.new
end

Dynamic Method Handling

This class handles dynamic methods through the method_missing method in the class Sequel::Database::AsyncThreadPool::BaseProxy