Contents

require 'thread'

module Innate
  module State
    # In case fibers are not available we fall back to this wrapper.
    #
    # It will raise errors happening inside the wrapping Thread even if
    # Thread::raise_on_exception is false.
    #
    # For things that require a mutex in a threaded environment, use
    # STATE#sync, if Fiber is available no mutex will be used.

    class Thread
      SEMAPHORE = Mutex.new

      def [](key)
        ::Thread.current[key]
      end

      def []=(key, value)
        ::Thread.current[key] = value
      end

      # Execute given block in a new Thread and rescue any exceptions before
      # they reach Thread::new, so in case Thread::raise_on_exception is false
      # we can still reraise the error outside of the Thread.

      def wrap
        value = ::Thread.new{ begin; yield; rescue Exception => ex; ex; end }.value
        raise(value) if Exception === value
        return value
      end

      def sync(&block)
        SEMAPHORE.synchronize(&block)
      end
    end
  end
end

Version data entries

3 entries across 3 versions & 1 rubygems

Version	Path
manveru-innate-2009.02.06	lib/innate/state/thread.rb
manveru-innate-2009.02.21	lib/innate/state/thread.rb
manveru-innate-2009.02.25	lib/innate/state/thread.rb