Method: Xunch::ThreadedRedisPool#destroy

Defined in:
lib/xunch/connection/threaded_redis_pool.rb

#destroy ⇒ Object 



23
24
25
26
27
28
29
30
31
32
33
 
# File 'lib/xunch/connection/threaded_redis_pool.rb', line 23

def destroy
  if !@closed
    @mutex.synchronize do
      if !@closed
        @closed = true
        @available.each {|redis| redis.quit if redis and redis.connected?}
        @reserved.each {|redis| redis.quit if redis and redis.connected?}
      end
    end
  end
end