Contents

#This module can be included on a class to make all method-calls synchronized (by using mutex). Examples with array and hash are below.
#
#===Examples
# class MySyncedClass < SomeOtherClassThatNeedsToBeSynchronized
#   include Tsafe::Mutexed
# end
module Tsafe::Mutexed
  def self.included(base)
    base.to_s.split("::").inject(Object, :const_get).class_eval do
      self.instance_methods.each do |method_name|
        #These two methods create warnings under JRuby.
        if RUBY_ENGINE == "jruby"
          next if method_name == :instance_exec or method_name == :instance_eval
        end
        
        new_method_name = "_ts_#{method_name}"
        alias_method(new_method_name, method_name)
        
        define_method method_name do |*args, &block|
          #Need to use monitor, since the internal calls might have to run not-synchronized, and we have just overwritten the internal methods.
          @_ts_mutex = Mutex.new if !@_ts_mutex
          @_ts_mutex.synchronize do
            return self._ts___send__(new_method_name, *args, &block)
          end
        end
      end
    end
  end
end

Version data entries

4 entries across 4 versions & 1 rubygems

Version	Path
tsafe-0.0.5	lib/tsafe_mutexed.rb
tsafe-0.0.4	include/mutexed.rb
tsafe-0.0.3	include/mutexed.rb
tsafe-0.0.2	include/mutexed.rb