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 : ruby_thread_local_var.rb

require 'thread'
require 'concurrent/atomic/abstract_thread_local_var'

module Concurrent

# @!visibility private
  # @!macro internal_implementation_note
  class RubyThreadLocalVar < AbstractThreadLocalVar

# Each thread has a (lazily initialized) array of thread-local variable values
    # Each time a new thread-local var is created, we allocate an "index" for it
    # For example, if the allocated index is 1, that means slot #1 in EVERY
    #   thread's thread-local array will be used for the value of that TLV
    #
    # The good thing about using a per-THREAD structure to hold values, rather
    #   than a per-TLV structure, is that no synchronization is needed when
    #    reading and writing those values (since the structure is only ever
    #    accessed by a single thread)
    #
    # Of course, when a TLV is GC'd, 1) we need to recover its index for use
    #   by other new TLVs (otherwise the thread-local arrays could get bigger
    #   and bigger with time), and 2) we need to null out all the references
    #   held in the now-unused slots (both to avoid blocking GC of those objects,
    #   and also to prevent "stale" values from being passed on to a new TLV
    #   when the index is reused)
    # Because we need to null out freed slots, we need to keep references to
    #   ALL the thread-local arrays -- ARRAYS is for that
    # But when a Thread is GC'd, we need to drop the reference to its thread-local
    #   array, so we don't leak memory

# @!visibility private
    FREE   = []
    LOCK   = Mutex.new
    ARRAYS = {} # used as a hash set
    @@next = 0
    private_constant :FREE, :LOCK, :ARRAYS

# @!macro thread_local_var_method_get
    def value
      if array = get_threadlocal_array
        value = array[@index]
        if value.nil?
          default
        elsif value.equal?(NULL)
          nil
        else
          value
        end
      else
        default
      end
    end

# @!macro thread_local_var_method_set
    def value=(value)
      me = Thread.current
      # We could keep the thread-local arrays in a hash, keyed by Thread
      # But why? That would require locking
      # Using Ruby's built-in thread-local storage is faster
      unless array = get_threadlocal_array(me)
        array = set_threadlocal_array([], me)
        LOCK.synchronize { ARRAYS[array.object_id] = array }
        ObjectSpace.define_finalizer(me, self.class.thread_finalizer(array))
      end
      array[@index] = (value.nil? ? NULL : value)
      value
    end

protected

# @!visibility private
    def allocate_storage
      @index = LOCK.synchronize do
        FREE.pop || begin
          result = @@next
          @@next += 1
          result
        end
      end
      ObjectSpace.define_finalizer(self, self.class.threadlocal_finalizer(@index))
    end

# @!visibility private
    def self.threadlocal_finalizer(index)
      proc do
        Thread.new do # avoid error: can't be called from trap context
          LOCK.synchronize do
            FREE.push(index)
            # The cost of GC'ing a TLV is linear in the number of threads using TLVs
            # But that is natural! More threads means more storage is used per TLV
            # So naturally more CPU time is required to free more storage
            ARRAYS.each_value do |array|
              array[index] = nil
            end
          end
        end
      end
    end

# @!visibility private
    def self.thread_finalizer(array)
      proc do
        Thread.new do # avoid error: can't be called from trap context
          LOCK.synchronize do
            # The thread which used this thread-local array is now gone
            # So don't hold onto a reference to the array (thus blocking GC)
            ARRAYS.delete(array.object_id)
          end
        end
      end
    end

private

if Thread.instance_methods.include?(:thread_variable_get)

def get_threadlocal_array(thread = Thread.current)
        thread.thread_variable_get(:__threadlocal_array__)
      end

def set_threadlocal_array(array, thread = Thread.current)
        thread.thread_variable_set(:__threadlocal_array__, array)
      end

else

def get_threadlocal_array(thread = Thread.current)
        thread[:__threadlocal_array__]
      end

def set_threadlocal_array(array, thread = Thread.current)
        thread[:__threadlocal_array__] = array
      end
    end

# This exists only for use in testing
    # @!visibility private
    def value_for(thread)
      if array = get_threadlocal_array(thread)
        value = array[@index]
        if value.nil?
          default_for(thread)
        elsif value.equal?(NULL)
          nil
        else
          value
        end
      else
        default_for(thread)
      end
    end

def default_for(thread)
      if @default_block
        raise "Cannot use default_for with default block"
      else
        @default
      end
    end
  end
end

${this.title}

Code Editor : ruby_thread_local_var.rb