Gecko [ lorencats.com ]

Name	Size	Permission
abstract_thread_local_var.rb	1.3 KB	-rw-r--r--
atomic_boolean.rb	3.8 KB	-rw-r--r--
atomic_fixnum.rb	4.51 KB	-rw-r--r--
atomic_reference.rb	1.27 KB	-rw-r--r--
count_down_latch.rb	3.24 KB	-rw-r--r--
cyclic_barrier.rb	3.99 KB	-rw-r--r--
event.rb	2.76 KB	-rw-r--r--
java_count_down_latch.rb	964 B	-rw-r--r--
java_thread_local_var.rb	691 B	-rw-r--r--
mutex_atomic_boolean.rb	1.23 KB	-rw-r--r--
mutex_atomic_fixnum.rb	1.55 KB	-rw-r--r--
mutex_count_down_latch.rb	970 B	-rw-r--r--
mutex_semaphore.rb	2.7 KB	-rw-r--r--
read_write_lock.rb	8.22 KB	-rw-r--r--
reentrant_read_write_lock.rb	13.87 KB	-rw-r--r--
ruby_thread_local_var.rb	4.85 KB	-rw-r--r--
semaphore.rb	4.15 KB	-rw-r--r--
thread_local_var.rb	3.01 KB	-rw-r--r--

Code Editor : thread_local_var.rb

require 'concurrent/atomic/ruby_thread_local_var'
require 'concurrent/atomic/java_thread_local_var'
require 'concurrent/utility/engine'

module Concurrent

###################################################################

# @!macro [new] thread_local_var_method_initialize
  #
  #   Creates a thread local variable.
  #
  #   @param [Object] default the default value when otherwise unset
  #   @param [Proc] default_block Optional block that gets called to obtain the
  #     default value for each thread

# @!macro [new] thread_local_var_method_get
  #
  #   Returns the value in the current thread's copy of this thread-local variable.
  #
  #   @return [Object] the current value

# @!macro [new] thread_local_var_method_set
  #
  #   Sets the current thread's copy of this thread-local variable to the specified value.
  #
  #   @param [Object] value the value to set
  #   @return [Object] the new value

# @!macro [new] thread_local_var_method_bind
  #
  #   Bind the given value to thread local storage during
  #   execution of the given block.
  #
  #   @param [Object] value the value to bind
  #   @yield the operation to be performed with the bound variable
  #   @return [Object] the value

###################################################################

# @!macro [new] thread_local_var_public_api
  #
  #   @!method initialize(default = nil)
  #     @!macro thread_local_var_method_initialize
  #
  #   @!method value
  #     @!macro thread_local_var_method_get
  #
  #   @!method value=(value)
  #     @!macro thread_local_var_method_set
  #
  #   @!method bind(value, &block)
  #     @!macro thread_local_var_method_bind

###################################################################

# @!visibility private
  # @!macro internal_implementation_note
  ThreadLocalVarImplementation = case
                                 when Concurrent.on_jruby?
                                   JavaThreadLocalVar
                                 else
                                   RubyThreadLocalVar
                                 end
  private_constant :ThreadLocalVarImplementation

# @!macro [attach] thread_local_var
  #
  #   A `ThreadLocalVar` is a variable where the value is different for each thread.
  #   Each variable may have a default value, but when you modify the variable only
  #   the current thread will ever see that change.
  #
  #   @!macro thread_safe_variable_comparison
  #
  #   @example
  #     v = ThreadLocalVar.new(14)
  #     v.value #=> 14
  #     v.value = 2
  #     v.value #=> 2
  #
  #   @example
  #     v = ThreadLocalVar.new(14)
  #
  #     t1 = Thread.new do
  #       v.value #=> 14
  #       v.value = 1
  #       v.value #=> 1
  #     end
  #
  #     t2 = Thread.new do
  #       v.value #=> 14
  #       v.value = 2
  #       v.value #=> 2
  #     end
  #
  #     v.value #=> 14
  #
  #   @see https://docs.oracle.com/javase/7/docs/api/java/lang/ThreadLocal.html Java ThreadLocal
  #
  # @!macro thread_local_var_public_api
  class ThreadLocalVar < ThreadLocalVarImplementation
  end
end

${this.title}

Code Editor : thread_local_var.rb