Packages

object Scheduler extends SchedulerCompanionImpl with Serializable

Source
Scheduler.scala
Linear Supertypes
Serializable, SchedulerCompanionImpl, SchedulerCompanion, AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. Scheduler
  2. Serializable
  3. SchedulerCompanionImpl
  4. SchedulerCompanion
  5. AnyRef
  6. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Type Members

  1. implicit final class Extensions extends AnyVal with ExecuteExtensions

    Utilities complementing the Scheduler interface.

  2. trait ImplicitsLike extends AnyRef
    Definition Classes
    SchedulerCompanion

Value Members

  1. final def !=(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  2. final def ##: Int
    Definition Classes
    AnyRef → Any
  3. final def ==(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  4. val BATCHING: Flag

    The Scheduler supports processing in batches via an internal trampoline.

    The Scheduler supports processing in batches via an internal trampoline.

    Schedulers that implement the batching behavior will recognize monix.execution.schedulers.TrampolinedRunnable instances (via instanceOf checks) and make an effort to execute them on the current thread.

    This flag is exposed via Scheduler.features.

    See also

    BatchingScheduler for an implementation.

  5. lazy val DefaultScheduledExecutor: ScheduledExecutorService

    The default ScheduledExecutor instance.

    The default ScheduledExecutor instance.

    Currently it's a single-threaded Java ScheduledExecutorService used for scheduling delayed tasks for execution. But the actual execution will not happen on this executor service. In general you can just reuse this one for all your scheduling needs.

    Definition Classes
    SchedulerCompanionImpl
  6. val TRACING: Flag

    Flag signaling that the Scheduler implementation can transport Local variables over async boundaries.

    Flag signaling that the Scheduler implementation can transport Local variables over async boundaries.

    See also

    TracingScheduler and TracingSchedulerService for implementations.

  7. def apply(executionModel: ExecutionModel): Scheduler

    Scheduler builder - uses monix's default ScheduledExecutorService for handling the scheduling of tasks.

    Scheduler builder - uses monix's default ScheduledExecutorService for handling the scheduling of tasks. Uses Scala's s.c.ExecutionContext.global for actual execution.

    executionModel

    is the preferred ExecutionModel, a guideline for run-loops and producers of data. Use ExecutionModel.Default for the default.

    Definition Classes
    SchedulerCompanionImpl
  8. def apply(reporter: UncaughtExceptionReporter, executionModel: ExecutionModel): Scheduler

    Scheduler builder - uses monix's default ScheduledExecutorService for handling the scheduling of tasks.

    Scheduler builder - uses monix's default ScheduledExecutorService for handling the scheduling of tasks. Uses Scala's s.c.ExecutionContext.global for actual execution.

    reporter

    is the UncaughtExceptionReporter that logs uncaught exceptions. Wrap the given ExecutionContext.reportFailure or use UncaughtExceptionReporter.default for the default.

    executionModel

    is the preferred ExecutionModel, a guideline for run-loops and producers of data. Use ExecutionModel.Default for the default.

    Definition Classes
    SchedulerCompanionImpl
  9. def apply(ec: ExecutionContext, executionModel: ExecutionModel): Scheduler

    Scheduler builder - uses monix's default ScheduledExecutorService for handling the scheduling of tasks.

    Scheduler builder - uses monix's default ScheduledExecutorService for handling the scheduling of tasks.

    ec

    is the execution context on top of which all tasks will run.

    executionModel

    is the preferred ExecutionModel, a guideline for run-loops and producers of data. Use ExecutionModel.Default for the default.

    Definition Classes
    SchedulerCompanionImpl
  10. def apply(ec: ExecutionContext): Scheduler

    Scheduler builder - uses monix's default ScheduledExecutorService for handling the scheduling of tasks.

    Scheduler builder - uses monix's default ScheduledExecutorService for handling the scheduling of tasks.

    ec

    is the execution context on top of which all tasks will run.

    Definition Classes
    SchedulerCompanionImpl
  11. def apply(executor: ExecutorService, executionModel: ExecutionModel): SchedulerService

    Scheduler builder that converts a Java ExecutorService into a scheduler.

    Scheduler builder that converts a Java ExecutorService into a scheduler.

    executor

    is the ScheduledExecutorService that handles the scheduling of tasks into the future. If not provided, an internal default will be used. You can also create one with java.util.concurrent.Executors.

    executionModel

    is the preferred ExecutionModel, a guideline for run-loops and producers of data. Use ExecutionModel.Default for the default.

    Definition Classes
    SchedulerCompanionImpl
  12. def apply(executor: ExecutorService): SchedulerService

    Scheduler builder that converts a Java ExecutorService into a scheduler.

    Scheduler builder that converts a Java ExecutorService into a scheduler.

    executor

    is the ScheduledExecutorService that handles the scheduling of tasks into the future. If not provided, an internal default will be used. You can also create one with java.util.concurrent.Executors.

    Definition Classes
    SchedulerCompanionImpl
  13. def apply(executor: ExecutorService, reporter: UncaughtExceptionReporter, executionModel: ExecutionModel): SchedulerService

    Scheduler builder that converts a Java ExecutorService into a scheduler.

    Scheduler builder that converts a Java ExecutorService into a scheduler.

    executor

    is the ScheduledExecutorService that handles the scheduling of tasks into the future. If not provided, an internal default will be used. You can also create one with java.util.concurrent.Executors.

    reporter

    is the UncaughtExceptionReporter that logs uncaught exceptions. Wrap the given ExecutionContext.reportFailure or use UncaughtExceptionReporter.default for the default.

    executionModel

    is the preferred ExecutionModel, a guideline for run-loops and producers of data. Use ExecutionModel.Default for the default.

    Definition Classes
    SchedulerCompanionImpl
  14. def apply(executor: ExecutorService, reporter: UncaughtExceptionReporter): SchedulerService

    Scheduler builder that converts a Java ExecutorService into a scheduler.

    Scheduler builder that converts a Java ExecutorService into a scheduler.

    executor

    is the ScheduledExecutorService that handles the scheduling of tasks into the future. If not provided, an internal default will be used. You can also create one with java.util.concurrent.Executors.

    reporter

    is the UncaughtExceptionReporter that logs uncaught exceptions. Wrap the given ExecutionContext.reportFailure or use UncaughtExceptionReporter.default for the default.

    Definition Classes
    SchedulerCompanionImpl
  15. def apply(ec: ExecutionContext, reporter: UncaughtExceptionReporter, executionModel: ExecutionModel): Scheduler

    Scheduler builder .

    Scheduler builder .

    ec

    is the execution context on top of which all tasks will run. Use scala.concurrent.ExecutionContext.Implicits.global for the default.

    reporter

    is the UncaughtExceptionReporter that logs uncaught exceptions. Wrap the given ExecutionContext.reportFailure or use UncaughtExceptionReporter.default for the default.

    executionModel

    is the preferred ExecutionModel, a guideline for run-loops and producers of data. Use ExecutionModel.Default for the default.

    Definition Classes
    SchedulerCompanionImpl
  16. def apply(ec: ExecutionContext, reporter: UncaughtExceptionReporter): Scheduler

    Scheduler builder.

    Scheduler builder.

    ec

    is the execution context on top of which all tasks will run. Use scala.concurrent.ExecutionContext.Implicits.global for the default.

    reporter

    is the UncaughtExceptionReporter that logs uncaught exceptions. Wrap the given ExecutionContext.reportFailure or use UncaughtExceptionReporter.default for the default.

    Definition Classes
    SchedulerCompanionImpl
  17. def apply(executor: ScheduledExecutorService, ec: ExecutionContext): Scheduler

    Scheduler builder.

    Scheduler builder.

    executor

    is the ScheduledExecutorService that handles the scheduling of tasks into the future. If not provided, an internal default will be used. You can also create one with java.util.concurrent.Executors.

    ec

    is the execution context on top of which all tasks will run. Use scala.concurrent.ExecutionContext.Implicits.global for the default.

    Definition Classes
    SchedulerCompanionImpl
  18. def apply(executor: ScheduledExecutorService, ec: ExecutionContext, reporter: UncaughtExceptionReporter, executionModel: ExecutionModel): Scheduler

    Scheduler builder.

    Scheduler builder.

    The resulting Scheduler will piggyback on top of a Java ScheduledExecutorService for scheduling tasks for execution with a delay and a Scala ExecutionContext for actually executing the tasks.

    executor

    is the ScheduledExecutorService that handles the scheduling of tasks into the future. If not provided, an internal default will be used. You can also create one with java.util.concurrent.Executors.

    ec

    is the execution context on top of which all tasks will run. Use scala.concurrent.ExecutionContext.Implicits.global for the default.

    reporter

    is the UncaughtExceptionReporter that logs uncaught exceptions. Wrap the given ExecutionContext.reportFailure or use UncaughtExceptionReporter.default for the default.

    executionModel

    is the preferred ExecutionModel, a guideline for run-loops and producers of data. Use ExecutionModel.Default for the default.

    Definition Classes
    SchedulerCompanionImpl
  19. final def asInstanceOf[T0]: T0
    Definition Classes
    Any
  20. def cached(name: String, minThreads: Int, maxThreads: Int, keepAliveTime: FiniteDuration = 60.seconds, daemonic: Boolean = true, reporter: UncaughtExceptionReporter = UncaughtExceptionReporter.default, executionModel: ExecutionModel = ExecModel.Default): SchedulerService

    Builds a Scheduler backed by an internal java.util.concurrent.ThreadPoolExecutor, that executes each submitted task using one of possibly several pooled threads.

    Builds a Scheduler backed by an internal java.util.concurrent.ThreadPoolExecutor, that executes each submitted task using one of possibly several pooled threads.

    name

    the created threads name prefix, for easy identification

    minThreads

    the number of threads to keep in the pool, even if they are idle

    maxThreads

    the maximum number of threads to allow in the pool

    keepAliveTime

    when the number of threads is greater than the core, this is the maximum time that excess idle threads will wait for new tasks before terminating

    daemonic

    specifies whether the created threads should be daemonic (non-daemonic threads are blocking the JVM process on exit).

    reporter

    is the UncaughtExceptionReporter that logs uncaught exceptions. Wrap the given ExecutionContext.reportFailure or use UncaughtExceptionReporter.default for the default.

    executionModel

    is the preferred ExecutionModel, a guideline for run-loops and producers of data. Use ExecutionModel.Default for the default.

    Definition Classes
    SchedulerCompanionImpl
  21. def clone(): AnyRef
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.CloneNotSupportedException]) @native() @HotSpotIntrinsicCandidate()
  22. def computation(parallelism: Int = Runtime.getRuntime.availableProcessors(), name: String = "monix-computation", daemonic: Boolean = true, reporter: UncaughtExceptionReporter = UncaughtExceptionReporter.default, executionModel: ExecutionModel = ExecModel.Default): SchedulerService

    Creates a Scheduler meant for computationally heavy CPU-bound tasks.

    Creates a Scheduler meant for computationally heavy CPU-bound tasks.

    Characteristics:

    - backed by a ForkJoinPool implementation, in async mode - uses monix's default ScheduledExecutorService instance for scheduling - DOES NOT cooperate with Scala's BlockContext

    parallelism

    is the number of threads that can run in parallel

    name

    the created threads name prefix, for easy identification.

    daemonic

    specifies whether the created threads should be daemonic (non-daemonic threads are blocking the JVM process on exit).

    reporter

    is the UncaughtExceptionReporter that logs uncaught exceptions. Wrap the given ExecutionContext.reportFailure or use UncaughtExceptionReporter.default for the default.

    executionModel

    is the preferred ExecutionModel, a guideline for run-loops and producers of data. Use ExecutionModel.Default for the default.

    Definition Classes
    SchedulerCompanionImpl
  23. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  24. def equals(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef → Any
  25. def fixedPool(name: String, poolSize: Int, daemonic: Boolean = true, reporter: UncaughtExceptionReporter = UncaughtExceptionReporter.default, executionModel: ExecutionModel = ExecModel.Default): SchedulerService

    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

    name

    the created threads name prefix, for easy identification.

    daemonic

    specifies whether the created thread should be daemonic

    reporter

    is the UncaughtExceptionReporter that logs uncaught exceptions.

    Definition Classes
    SchedulerCompanionImpl
  26. def forkJoin(parallelism: Int, maxThreads: Int, name: String = "monix-forkjoin", daemonic: Boolean = true, reporter: UncaughtExceptionReporter = UncaughtExceptionReporter.default, executionModel: ExecutionModel = ExecModel.Default): SchedulerService

    Creates a general purpose Scheduler backed by a ForkJoinPool, similar to Scala's global.

    Creates a general purpose Scheduler backed by a ForkJoinPool, similar to Scala's global.

    Characteristics:

    - backed by a ForkJoinPool implementation, in async mode - uses monix's default ScheduledExecutorService instance for scheduling - cooperates with Scala's BlockContext

    parallelism

    is the number of threads that can run in parallel

    maxThreads

    is the maximum number of threads that can be created

    name

    the created threads name prefix, for easy identification.

    daemonic

    specifies whether the created threads should be daemonic (non-daemonic threads are blocking the JVM process on exit).

    reporter

    is the UncaughtExceptionReporter that logs uncaught exceptions. Wrap the given ExecutionContext.reportFailure or use UncaughtExceptionReporter.default for the default.

    executionModel

    is the preferred ExecutionModel, a guideline for run-loops and producers of data. Use ExecutionModel.Default for the default.

    Definition Classes
    SchedulerCompanionImpl
  27. final def getClass(): Class[_ <: AnyRef]
    Definition Classes
    AnyRef → Any
    Annotations
    @native() @HotSpotIntrinsicCandidate()
  28. def global: Scheduler

    The explicit global Scheduler.

    The explicit global Scheduler. Invoke global when you want to provide the global Scheduler explicitly.

    The default Scheduler implementation is backed by a work-stealing thread pool, along with a single-threaded ScheduledExecutionContext that does the scheduling. By default, the thread pool uses a target number of worker threads equal to the number of available processors.

    returns

    the global Scheduler

    Definition Classes
    SchedulerCompanionImpl → SchedulerCompanion
  29. def hashCode(): Int
    Definition Classes
    AnyRef → Any
    Annotations
    @native() @HotSpotIntrinsicCandidate()
  30. def io(name: String = "monix-io", daemonic: Boolean = true, reporter: UncaughtExceptionReporter = UncaughtExceptionReporter.default, executionModel: ExecutionModel = ExecModel.Default): SchedulerService

    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 monix's default ScheduledExecutorService instance for scheduling - doesn't cooperate with Scala's BlockContext because it is unbounded

    name

    the created threads name prefix, for easy identification.

    daemonic

    specifies whether the created threads should be daemonic (non-daemonic threads are blocking the JVM process on exit).

    reporter

    is the UncaughtExceptionReporter that logs uncaught exceptions. Wrap the given ExecutionContext.reportFailure or use UncaughtExceptionReporter.default for the default.

    executionModel

    is the preferred ExecutionModel, a guideline for run-loops and producers of data. Use ExecutionModel.Default for the default.

    Definition Classes
    SchedulerCompanionImpl
  31. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  32. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  33. final def notify(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native() @HotSpotIntrinsicCandidate()
  34. final def notifyAll(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native() @HotSpotIntrinsicCandidate()
  35. def singleThread(name: String, daemonic: Boolean = true, reporter: UncaughtExceptionReporter = UncaughtExceptionReporter.default, executionModel: ExecutionModel = ExecModel.Default): SchedulerService

    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

    name

    is the name of the created thread, for easy identification

    daemonic

    specifies whether the created thread should be daemonic (non-daemonic threads are blocking the JVM process on exit)

    reporter

    is the UncaughtExceptionReporter that logs uncaught exceptions. Wrap the given ExecutionContext.reportFailure or use UncaughtExceptionReporter.default for the default.

    executionModel

    is the preferred ExecutionModel, a guideline for run-loops and producers of data. Use ExecutionModel.Default for the default.

    Definition Classes
    SchedulerCompanionImpl
  36. final def synchronized[T0](arg0: => T0): T0
    Definition Classes
    AnyRef
  37. def toString(): String
    Definition Classes
    AnyRef → Any
  38. def traced: Scheduler

    A global Scheduler instance that does propagation of Local.Context on async execution.

    A global Scheduler instance that does propagation of Local.Context on async execution.

    It wraps global.

    Definition Classes
    SchedulerCompanionImpl → SchedulerCompanion
  39. def trampoline(underlying: Scheduler = Implicits.global, executionModel: ExecutionModel = ExecModel.Default): Scheduler

    Builds a TrampolineScheduler.

    Builds a TrampolineScheduler.

    underlying

    is the Scheduler to which the we defer to in case asynchronous or time-delayed execution is needed

    Definition Classes
    SchedulerCompanionImpl
  40. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])
  41. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException]) @native()
  42. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])
  43. object Implicits extends schedulers.SchedulerCompanionImpl.ImplicitsLike

    Definition Classes
    SchedulerCompanionImpl → SchedulerCompanion

Deprecated Value Members

  1. def finalize(): Unit
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.Throwable]) @Deprecated
    Deprecated

Inherited from Serializable

Inherited from SchedulerCompanionImpl

Inherited from SchedulerCompanion

Inherited from AnyRef

Inherited from Any

Ungrouped