com.atlassian.vcache.internal.redis

Class ThreadAffinityJedisPool

java.lang.Object

redis.clients.util.Pool<redis.clients.jedis.Jedis>

redis.clients.jedis.JedisPool

com.atlassian.vcache.internal.redis.ThreadAffinityJedisPool

All Implemented Interfaces:

Closeable, AutoCloseable

public class ThreadAffinityJedisPool
extends redis.clients.jedis.JedisPool

A specialised JedisPool which binds the currently in-use Jedis instance to the requesting thread, so that repeated calls to getResource() without a corresponding returnResource(Jedis) will return the same instance. A reference count is kept for each thread-bound instance, and when an instance is returned and the reference count reaches zero, the instance is returned to the pool for real.

Since:

1.10.1

Field Summary

Fields inherited from class redis.clients.util.Pool

internalPool

Constructor Summary

Constructors

Constructor and Description
ThreadAffinityJedisPool()
ThreadAffinityJedisPool(org.apache.commons.pool2.impl.GenericObjectPoolConfig poolConfig, String host)
ThreadAffinityJedisPool(org.apache.commons.pool2.impl.GenericObjectPoolConfig poolConfig, String host, int port)
ThreadAffinityJedisPool(org.apache.commons.pool2.impl.GenericObjectPoolConfig poolConfig, String host, int port, int timeout)
ThreadAffinityJedisPool(org.apache.commons.pool2.impl.GenericObjectPoolConfig poolConfig, String host, int port, int connectionTimeout, int soTimeout, String password, int database, String clientName)
ThreadAffinityJedisPool(org.apache.commons.pool2.impl.GenericObjectPoolConfig poolConfig, String host, int port, int timeout, String password)
ThreadAffinityJedisPool(org.apache.commons.pool2.impl.GenericObjectPoolConfig poolConfig, String host, int port, int timeout, String password, int database)
ThreadAffinityJedisPool(org.apache.commons.pool2.impl.GenericObjectPoolConfig poolConfig, String host, int port, int timeout, String password, int database, String clientName)
ThreadAffinityJedisPool(org.apache.commons.pool2.impl.GenericObjectPoolConfig poolConfig, URI uri)
ThreadAffinityJedisPool(org.apache.commons.pool2.impl.GenericObjectPoolConfig poolConfig, URI uri, int timeout)
ThreadAffinityJedisPool(org.apache.commons.pool2.impl.GenericObjectPoolConfig poolConfig, URI uri, int connectionTimeout, int soTimeout)
ThreadAffinityJedisPool(String host)
ThreadAffinityJedisPool(String host, int port)
ThreadAffinityJedisPool(URI uri)
ThreadAffinityJedisPool(URI uri, int timeout)

Method Summary

Modifier and Type	Method and Description
redis.clients.jedis.Jedis	getResource()
void	returnBrokenResource(redis.clients.jedis.Jedis jedis)
void	returnResource(redis.clients.jedis.Jedis jedis)

Methods inherited from class redis.clients.util.Pool

addObjects, close, closeInternalPool, destroy, getMaxBorrowWaitTimeMillis, getMeanBorrowWaitTimeMillis, getNumActive, getNumIdle, getNumWaiters, initPool, isClosed, returnBrokenResourceObject, returnResourceObject

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ThreadAffinityJedisPool

public ThreadAffinityJedisPool()

ThreadAffinityJedisPool

public ThreadAffinityJedisPool(org.apache.commons.pool2.impl.GenericObjectPoolConfig poolConfig,
                               String host)

ThreadAffinityJedisPool

public ThreadAffinityJedisPool(String host,
                               int port)

ThreadAffinityJedisPool

public ThreadAffinityJedisPool(String host)

ThreadAffinityJedisPool

public ThreadAffinityJedisPool(URI uri)

ThreadAffinityJedisPool

public ThreadAffinityJedisPool(URI uri,
                               int timeout)

ThreadAffinityJedisPool

public ThreadAffinityJedisPool(org.apache.commons.pool2.impl.GenericObjectPoolConfig poolConfig,
                               String host,
                               int port,
                               int timeout,
                               String password)

ThreadAffinityJedisPool

public ThreadAffinityJedisPool(org.apache.commons.pool2.impl.GenericObjectPoolConfig poolConfig,
                               String host,
                               int port)

ThreadAffinityJedisPool

public ThreadAffinityJedisPool(org.apache.commons.pool2.impl.GenericObjectPoolConfig poolConfig,
                               String host,
                               int port,
                               int timeout)

ThreadAffinityJedisPool

public ThreadAffinityJedisPool(org.apache.commons.pool2.impl.GenericObjectPoolConfig poolConfig,
                               String host,
                               int port,
                               int timeout,
                               String password,
                               int database)

ThreadAffinityJedisPool

public ThreadAffinityJedisPool(org.apache.commons.pool2.impl.GenericObjectPoolConfig poolConfig,
                               String host,
                               int port,
                               int timeout,
                               String password,
                               int database,
                               String clientName)

ThreadAffinityJedisPool

public ThreadAffinityJedisPool(org.apache.commons.pool2.impl.GenericObjectPoolConfig poolConfig,
                               String host,
                               int port,
                               int connectionTimeout,
                               int soTimeout,
                               String password,
                               int database,
                               String clientName)

ThreadAffinityJedisPool

public ThreadAffinityJedisPool(org.apache.commons.pool2.impl.GenericObjectPoolConfig poolConfig,
                               URI uri)

ThreadAffinityJedisPool

public ThreadAffinityJedisPool(org.apache.commons.pool2.impl.GenericObjectPoolConfig poolConfig,
                               URI uri,
                               int timeout)

ThreadAffinityJedisPool

public ThreadAffinityJedisPool(org.apache.commons.pool2.impl.GenericObjectPoolConfig poolConfig,
                               URI uri,
                               int connectionTimeout,
                               int soTimeout)

Method Detail

getResource

public redis.clients.jedis.Jedis getResource()

Overrides:

getResource in class redis.clients.jedis.JedisPool

returnBrokenResource

public void returnBrokenResource(redis.clients.jedis.Jedis jedis)

Overrides:

returnBrokenResource in class redis.clients.jedis.JedisPool

returnResource

public void returnResource(redis.clients.jedis.Jedis jedis)

Overrides:

returnResource in class redis.clients.jedis.JedisPool