Contents

require 'concurrent/atomic/abstract_thread_local_var'

if Concurrent.on_jruby?

  module Concurrent

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

      # @!macro thread_local_var_method_get
      def value
        value = @var.get

        if value.nil?
          @default
        elsif value == NIL_SENTINEL
          nil
        else
          value
        end
      end

      # @!macro thread_local_var_method_set
      def value=(value)
        @var.set(value)
      end

      # @!macro thread_local_var_method_bind
      def bind(value, &block)
        if block_given?
          old_value = @var.get
          begin
            @var.set(value)
            yield
          ensure
            @var.set(old_value)
          end
        end
      end

      protected

      # @!visibility private
      def allocate_storage
        @var = java.lang.ThreadLocal.new
      end
    end
  end
end

Version data entries

4 entries across 4 versions & 1 rubygems

Version	Path
concurrent-ruby-1.0.0.pre2-java	lib/concurrent/atomic/java_thread_local_var.rb
concurrent-ruby-1.0.0.pre2	lib/concurrent/atomic/java_thread_local_var.rb
concurrent-ruby-1.0.0.pre1	lib/concurrent/atomic/java_thread_local_var.rb
concurrent-ruby-1.0.0.pre1-java	lib/concurrent/atomic/java_thread_local_var.rb