class Sequel::Database::AsyncThreadPool::Proxy
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).
Public Class Methods
new()
click to toggle source
Calls superclass method
Sequel::Database::AsyncThreadPool::BaseProxy::new
# File lib/sequel/extensions/async_thread_pool.rb 304 def initialize 305 super 306 @queue = ::Queue.new 307 end