Class: Redis::Client::ThreadSafe

Inherits:

Redis::Client

• Object
• Redis::Client
• Redis::Client::ThreadSafe

Defined in:

lib/redis/client.rb

Instance Attribute Summary

Attributes inherited from Redis::Client

#connection, #db, #host, #logger, #password, #port, #timeout

Instance Method Summary

• #ensure_connected(&block) ⇒ Object
• #initialize(*args) ⇒ ThreadSafe constructor

  A new instance of ThreadSafe.

• #synchronize(&block) ⇒ Object

Methods inherited from Redis::Client

#call, #call_loop, #call_pipelined, #call_without_timeout, #connect, #connected?, #disconnect, #id, #process, #read, #reconnect, #without_socket_timeout

Constructor Details

#initialize(*args) ⇒ ThreadSafe

# File 'lib/redis/client.rb', line 168

def initialize(*args)
  require "monitor"

  super(*args)
  @mutex = ::Monitor.new
end

Instance Method Details

#ensure_connected(&block) ⇒ Object

# File 'lib/redis/client.rb', line 179

def ensure_connected(&block)
  synchronize { super }
end

#synchronize(&block) ⇒ Object

# File 'lib/redis/client.rb', line 175

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