Contents

require 'fiber'

module Innate
  # Innate subclasses Fiber to enable lightweight request/respose-cycle local
  # variables.
  #
  # We do that by adding a state Hash to the Fiber instance on initalization
  # which can be accessed by #[], #[]= and #key?. Other Hash methods are not
  # necessary right now but may be added.
  #
  # We subclass to keep your Ruby clean and polished.
  #
  # TODO:
  #   * 1.9.1 includes a patch from matz that will call #initialize, so we can
  #     remove our ::new hack, just have to get my hands on a properly
  #     compiling version of 1.9.1
  class Fiber < ::Fiber
    attr_accessor :state

    def self.new(*args)
      instance = super
      instance.state = {}
      instance
    end

    def [](key)
      state[key]
    end

    def []=(key, value)
      state[key] = value
    end

    def key?(key)
      state.key?(key)
    end
  end

  module State
    # Our accessor to the currently active Fiber, an instance of
    # Innate::State::Fiber will be assigned to Innate::STATE if fibers are
    # available.
    class Fiber
      def [](key)
        Innate::Fiber.current[key]
      end

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

      # We don't use Fiber in a concurrent manner and they don't run
      # concurrently by themselves, so we directly #resume the Fiber to get the
      # return value of +block+.

      def wrap(&block)
        Innate::Fiber.new(&block).resume
      end

      # In an environment where only Fiber is used there is no concurrency, so
      # we don't have to lock with a Mutex.

      def sync
        yield
      end
    end
  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
manveru-innate-2009.02.06	lib/innate/state/fiber.rb