class Redis::Client::ThreadSafe

def synchronize(&block)

def synchronize(&block)
  @mutex.synchronize(&block)
end