final class TrampolineExecutionContext extends ExecutionContext
A scala.concurrentExecutionContext
implementation
that executes runnables immediately, on the current thread,
by means of a trampoline implementation.
Can be used in some cases to keep the asynchronous execution on the current thread, as an optimization, but be warned, you have to know what you're doing.
The TrampolineExecutionContext
keeps a reference to another
underlying
context, to which it defers for:
- reporting errors
- deferring the rest of the queue in problematic situations
Deferring the rest of the queue happens:
- in case we have a runnable throwing an exception, the rest
of the tasks get re-scheduled for execution by using
the
underlying
context - in case we have a runnable triggering a Scala
blocking
context, the rest of the tasks get re-scheduled for execution on theunderlying
context to prevent any deadlocks
Thus this implementation is compatible with the
scala.concurrent.BlockContext
, detecting blocking
blocks and
reacting by forking the rest of the queue to prevent deadlocks.
Linear Supertypes
Ordering
- Alphabetic
- By Inheritance
Inherited
- TrampolineExecutionContext
- ExecutionContext
- AnyRef
- Any
- Hide All
- Show All
Visibility
- Public
- All
Value Members
-
def
execute(runnable: Runnable): Unit
- Definition Classes
- TrampolineExecutionContext → ExecutionContext
-
def
reportFailure(t: Throwable): Unit
- Definition Classes
- TrampolineExecutionContext → ExecutionContext
Deprecated Value Members
-
def
prepare(): ExecutionContext
- Definition Classes
- ExecutionContext
- Annotations
- @deprecated
- Deprecated
(Since version 2.12.0) preparation of ExecutionContexts will be removed
This is the API documentation for the Monix library.
Package Overview
monix.execution exposes lower level primitives for dealing with asynchronous execution:
Atomic
types, as alternative tojava.util.concurrent.atomic
monix.eval is for dealing with evaluation of results, thus exposing Task and Coeval.
monix.reactive exposes the
Observable
pattern:Observable
implementationsmonix.types implements type-class shims, to be translated to type-classes provided by libraries such as Cats or Scalaz.
monix.cats is the optional integration with the Cats library, providing translations for the types described in
monix.types
.monix.scalaz is the optional integration with the Scalaz library, providing translations for the types described in
monix.types
.