sealed class CoroutineChannelGroup
(source)
A grouping of co-routine channels for the purpose of resource sharing.
A co-routine channel group encapsulates the mechanics required to handle completion of suspended I/O operations initiated on channels bound to the group.
isShutdown |
Check if the group has been shutdown. abstract val isShutdown: Boolean |
isTerminated |
Check if the group has terminated. abstract val isTerminated: Boolean |
awaitTermination |
Suspend until the group has terminated. abstract suspend fun awaitTermination(): Unit |
shutdown |
Shuts down the group. abstract fun shutdown(): Unit |
shutdownNow |
Shuts down the group and closes all open channels in the group. abstract fun shutdownNow(): Unit |
open |
Create a co-routine channel group. fun open(nSelectors: Int = Runtime.getRuntime().availableProcessors(), executor: Executor = Executors.newFixedThreadPool(nSelectors, CoroutineSelector.DEFAULT_THREAD_FACTORY), selectTimeout: Long = 1000, idleTimeout: Long = 10000): CoroutineChannelGroup |