class Redis::Client::ThreadSafe

def initialize(*args)

def initialize(*args)
  require "monitor"
  super(*args)
  @mutex = ::Monitor.new
end