//misk/misk.concurrent

Package-level declarations

Types

Name	Summary
ExecutorServiceModule	[jvm] class ExecutorServiceModule(annotation: KClass<out Annotation>, createFunction: (ExecutorServiceFactory) -> ExecutorService) : KAbstractModule Install this to bind an executor service with annotation. The executor service will be automatically shut down when the service shuts down.
ExplicitReleaseBlockingQueue	[jvm] class ExplicitReleaseBlockingQueue<T> : BlockingQueue<T> An ExplicitReleaseBlockingQueue is a BlockingQueue that only returns elements from BlockingQueue.take, BlockingQueue.poll, and BlockingQueue.peek after a call to ExplicitReleaseBlockingQueue.release. Used by tests that want to explicitly control when pollers receive queued items.
ExplicitReleaseDelayQueue	[jvm] class ExplicitReleaseDelayQueue<T : Delayed> : BlockingQueue<T> An ExplicitReleaseDelayQueue is an ExplicitReleaseBlockingQueue that release elements in the order in which they expire
WrappingListeningExecutorService	[jvm] abstract class WrappingListeningExecutorService : ForwardingListeningExecutorService ListeningExecutorService which wraps all calls