ExecutionPolicy
Controls the dispatchers and concurrency limits for a Server 's suspending operations.
Source and package
- public class ExecutionPolicy( public val commands: Coroutine
Dispatcher , public val streamReads: CoroutineDispatcher , public val defaultDeadline: Duration = Duration.INFINITE, ) -
Description#
Two independently sized pools, not one:
commandsbacks everysuspendoperation this module generates or hand-writes, sized from the transport's own admission bound rather than a guess.streamReadsbacks only what still genuinely blocks a thread —Server.liveState's background pump.ControlClient.outputandControlClient.eventshold no thread from either pool; they are built onio.github.libtmux.control.EventSubscription.pollandonReady, not on a blocking read.- Parameters
-
-
commands ( Coroutine
Dispatcher ) -
streamReads ( Coroutine
Dispatcher ) -
defaultDeadline ( Duration )
-
Discussed in Getting started
Members4 members#
Common operations2 members#
- commands property
- streamReads property
Other members2 members#
- Companion module
- defaultDeadline property