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

DispatcherBulkhead

Isolation-by-dispatcher bulkhead: like Bulkhead, but every admitted call runs on a dedicated CoroutineDispatcher instead of the caller's context.

A semaphore-only Bulkhead bounds concurrency but a slow/blocking call still occupies the caller's threads. Running the protected work on its own dispatcher (e.g. a fixed thread pool, see ThreadPoolBulkhead on the JVM) keeps a slow dependency from starving the rest of the application.

val bulkhead = DispatcherBulkhead.create(Dispatchers.IO.limitedParallelism(4))
bulkhead.execute { blockingCall() }

Types

Companion

object Companion

Factory for DispatcherBulkhead.

Properties

config

val config: BulkheadConfig

The configuration of the underlying permit/queue bulkhead.

dispatcher

val dispatcher: CoroutineDispatcher

Dispatcher on which admitted calls run.

Functions

activeCalls

suspend fun activeCalls(): Int

Returns the current number of active calls.

addListener

fun addListener(listener: BulkheadListener)

Adds a listener for bulkhead events.

execute

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

Executes block on dispatcher once a permit is available.

executeOrFallback

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

Like execute but runs fallback when rejected.

resetStatistics

suspend fun resetStatistics()

Resets all statistics counters.

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.

Inherited functions

asPolicy

fun DispatcherBulkhead.asPolicy(): Policy

Adapts this DispatcherBulkhead into a Policy.