Gecko [ lorencats.com ]

Name	Size	Permission
util	[ DIR ]	drwxr-xr-x
atomic_reference_cache_backend...	33.9 KB	-rw-r--r--
cache.rb	4.42 KB	-rw-r--r--
mri_cache_backend.rb	1.45 KB	-rw-r--r--
non_concurrent_cache_backend.r...	2.66 KB	-rw-r--r--
synchronized_cache_backend.rb	1.32 KB	-rw-r--r--
synchronized_delegator.rb	1.19 KB	-rw-r--r--
util.rb	700 B	-rw-r--r--
version.rb	492 B	-rw-r--r--

Code Editor : mri_cache_backend.rb

module ThreadSafe
  class MriCacheBackend < NonConcurrentCacheBackend
    # We can get away with a single global write lock (instead of a per-instance
    # one) because of the GVL/green threads.
    #
    # NOTE: a neat idea of writing a c-ext to manually perform atomic
    # put_if_absent, while relying on Ruby not releasing a GVL while calling a
    # c-ext will not work because of the potentially Ruby implemented `#hash`
    # and `#eql?` key methods.
    WRITE_LOCK = Mutex.new

def []=(key, value)
      WRITE_LOCK.synchronize { super }
    end

def compute_if_absent(key)
      if stored_value = _get(key) # fast non-blocking path for the most likely case
        stored_value
      else
        WRITE_LOCK.synchronize { super }
      end
    end

def compute_if_present(key)
      WRITE_LOCK.synchronize { super }
    end

def compute(key)
      WRITE_LOCK.synchronize { super }
    end

def merge_pair(key, value)
      WRITE_LOCK.synchronize { super }
    end

def replace_pair(key, old_value, new_value)
      WRITE_LOCK.synchronize { super }
    end

def replace_if_exists(key, new_value)
      WRITE_LOCK.synchronize { super }
    end

def get_and_set(key, value)
      WRITE_LOCK.synchronize { super }
    end

def delete(key)
      WRITE_LOCK.synchronize { super }
    end

def delete_pair(key, value)
      WRITE_LOCK.synchronize { super }
    end

def clear
      WRITE_LOCK.synchronize { super }
    end
  end
end

${this.title}

Code Editor : mri_cache_backend.rb