class Sequel::Database::AsyncThreadPool::PreemptableProxy
Object
class for async job/proxy result when the :preempt_async_thread Database
option is used. Uses a mutex for synchronization, and either the JobProcessor
or the calling thread can run code to get the value.
Public Class Methods
new()
click to toggle source
Calls superclass method
Sequel::Database::AsyncThreadPool::BaseProxy::new
# File lib/sequel/extensions/async_thread_pool.rb 328 def initialize 329 super 330 @mutex = ::Mutex.new 331 end
Private Instance Methods
__get_value()
click to toggle source
# File lib/sequel/extensions/async_thread_pool.rb 335 def __get_value 336 @mutex.synchronize do 337 unless defined?(@value) 338 @value = __run_block 339 end 340 end 341 end
Also aliased as: __run