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, line 327 def initialize super @mutex = ::Mutex.new end
Private Instance Methods
__get_value()
click to toggle source
# File lib/sequel/extensions/async_thread_pool.rb, line 334 def __get_value @mutex.synchronize do unless defined?(@value) @value = __run_block end end end
Also aliased as: __run