Arrow Resilience Kit/com.sorinirmies.arrow.resiliencekit/ThreadPoolBulkhead

ThreadPoolBulkhead

class ThreadPoolBulkhead : AutoCloseable

Thread-pool-isolation bulkhead (JVM). Admitted calls run on a dedicated fixed-size thread pool of BulkheadConfig.maxConcurrentCalls threads, so slow or blocking calls can never consume threads outside the pool.

Must be closed to release its threads.

ThreadPoolBulkhead.create("payments", BulkheadConfig(maxConcurrentCalls = 8)).use { b ->
    b.execute { blockingJdbcCall() }
}

Types

Companion

object Companion

Factory for ThreadPoolBulkhead.

Properties

config

val config: BulkheadConfig

The configuration of this bulkhead.

Functions

activeCalls

suspend fun activeCalls(): Int

Returns the current number of active calls.

addListener

fun addListener(listener: BulkheadListener)

Adds a listener for bulkhead events.

asPolicy

fun asPolicy(): Policy

Adapts this bulkhead into a Policy.

open override fun close()

Shuts the thread pool down.

execute

suspend fun <T> execute(block: suspend () -> T): T

Executes block on the dedicated pool; see DispatcherBulkhead.execute.

executeOrFallback

suspend fun <T> executeOrFallback(fallback: suspend () -> T, block: suspend () -> T): T

Like execute but runs fallback when rejected.

statistics

suspend fun statistics(): BulkheadStatistics

Returns a snapshot of the current statistics.

tryExecute

suspend fun <T> tryExecute(block: suspend () -> T): T?

Like execute but returns null when rejected.