Scheduler
Related Docs:
trait Scheduler
| package concurrent
Information about the environment on top of which our scheduler runs on.
Represents the platform our scheduler runs on.
Scheduler builder - uses Monifu's default ScheduledExecutorService for
handling the scheduling of tasks.
Scheduler builder - uses Monifu's default ScheduledExecutorService for
handling the scheduling of tasks.
is the execution context in which all tasks will run.
Scheduler builder that converts a Java ScheduledExecutorService into
a scheduler.
Scheduler builder that converts a Java ScheduledExecutorService into
a scheduler.
is the executor under which all tasks will run.
is the UncaughtExceptionReporter that logs uncaught exceptions.
Scheduler builder - uses Monifu's default ScheduledExecutorService for
handling the scheduling of tasks.
Scheduler builder - uses Monifu's default ScheduledExecutorService for
handling the scheduling of tasks.
is the execution context in which all tasks will run.
is the UncaughtExceptionReporter that logs uncaught exceptions.
Scheduler builder.
Scheduler builder.
is the ScheduledExecutorService that handles the scheduling
of tasks into the future.
is the execution context in which all tasks will run.
Scheduler builder.
Scheduler builder.
is the ScheduledExecutorService that handles the scheduling
of tasks into the future.
is the execution context in which all tasks will run.
is the UncaughtExceptionReporter that logs uncaught exceptions.
Creates a Scheduler meant for computational heavy tasks.
Creates a Scheduler meant for computational heavy tasks.
Characteristics:
- backed by Scala's ForkJoinPool for the task execution, in async mode
- uses Monifu's default ScheduledExecutorService instance for scheduling
- all created threads are daemonic
- cooperates with Scala's BlockContext
is the number of threads that can run in parallel
is the UncaughtExceptionReporter that logs uncaught exceptions.
Builds a Scheduler with a fixed thread-pool.
Builds a Scheduler with a fixed thread-pool.
Characteristics:
- backed by a fixed pool ScheduledExecutorService that takes care
of both scheduling tasks in the future and of executing immediate tasks
- does not cooperate with Scala's BlockingContext, so tasks should not
block on the result of other tasks scheduled to run on this same thread
is the name of the created thread, for easy identification
specifies whether the created thread should be daemonic
is the UncaughtExceptionReporter that logs uncaught exceptions.
Creates a Scheduler meant for blocking I/O tasks.
Creates a Scheduler meant for blocking I/O tasks.
Characteristics:
- backed by a cached ThreadPool executor with 60 seconds of keep-alive
- the maximum number of threads is unbounded, as recommended for blocking I/O
- uses Monifu's default ScheduledExecutorService instance for scheduling
- doesn't cooperate with Scala's BlockContext only because it is unbounded
the created threads name prefix, for easy identification.
specifies whether the created threads should be daemonic (non-daemonic threads are blocking the JVM process on exit).
is the UncaughtExceptionReporter that logs uncaught exceptions.
Builds a Scheduler that schedules and executes tasks on its own thread.
Builds a Scheduler that schedules and executes tasks on its own thread.
Characteristics:
- backed by a single-threaded ScheduledExecutorService that takes care
of both scheduling tasks in the future and of executing tasks
- does not cooperate with Scala's BlockingContext, so tasks should not
block on the result of other tasks scheduled to run on this same thread
is the name of the created thread, for easy identification
specifies whether the created thread should be daemonic
is the UncaughtExceptionReporter that logs uncaught exceptions.