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
# 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
__run()
Alias for: __get_value