redis-daemon/dev.ust.zinc.grader.daemon.messengers/Redis/RecoverableJedisPool

RecoverableJedisPool

private class RecoverableJedisPool : AutoCloseable

Encapsulation of JedisPool which supports AutoCloseable semantics for Jedis instance operations and connection pool recovery (e.g. when all connections of the pool cannot be used).

All methods in this class is thread-safe.

Constructors

constructor()

Properties

isClosed

val isClosed: Boolean

Whether the JedisPool is closed.

lock

private val lock: ReentrantReadWriteLock

ReentrantReadWriteLock guarding mutual exclusion of the pool.

pool

private var pool: JedisPool

JedisPool backing this instance.

Functions

open override fun close()

createJedisPool

private fun createJedisPool(): JedisPool

Creates a JedisPool using the current, active configuration.

recreatePool

private fun recreatePool(): JedisPool?

Recreates the Jedis connection pool.

resetPool

fun resetPool()

Resets the current pool by invoking AutoCloseable.close on the pool, then recreating the pool using the currently active configuration.

resetPoolSuspend

suspend fun resetPoolSuspend()

Similar to resetPool, but closes the old pool in a coroutine to avoid blocking the executing thread.

useConnection

fun <T> useConnection(block: (Jedis) -> T): T

Obtains a Jedis instance from the pool, executes block, and closes the connection at the end.

useConnectionSuspend

suspend fun <T> useConnectionSuspend(context: CoroutineContext = Dispatchers.IO, block: suspend (Jedis) -> T): T

Similar to useConnection, but executes block in a coroutine context.