Object/Trait

monifu.concurrent

Scheduler

Related Docs: trait Scheduler | package concurrent

Permalink

object Scheduler extends SchedulerCompanion

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

Type Members

  1. final class Environment extends AnyRef

    Permalink

    Information about the environment on top of which our scheduler runs on.

Value Members

  1. final def !=(arg0: Any): Boolean

    Permalink
    Definition Classes
    AnyRef → Any
  2. final def ##(): Int

    Permalink
    Definition Classes
    AnyRef → Any
  3. final def ==(arg0: Any): Boolean

    Permalink
    Definition Classes
    AnyRef → Any
  4. object Environment

    Permalink
  5. object Platform extends Enumeration

    Permalink

    Represents the platform our scheduler runs on.

  6. def apply(ec: ExecutionContext): Scheduler

    Permalink

    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.

    ec

    is the execution context in which all tasks will run.

    Definition Classes
    SchedulerCompanion
  7. def apply(executor: ScheduledExecutorService, r: UncaughtExceptionReporter): Scheduler

    Permalink

    Scheduler builder that converts a Java ScheduledExecutorService into a scheduler.

    Scheduler builder that converts a Java ScheduledExecutorService into a scheduler.

    executor

    is the executor under which all tasks will run.

    r

    is the UncaughtExceptionReporter that logs uncaught exceptions.

    Definition Classes
    SchedulerCompanion
  8. def apply(ec: ExecutionContext, r: UncaughtExceptionReporter): Scheduler

    Permalink

    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.

    ec

    is the execution context in which all tasks will run.

    r

    is the UncaughtExceptionReporter that logs uncaught exceptions.

    Definition Classes
    SchedulerCompanion
  9. def apply(executor: ScheduledExecutorService, ec: ExecutionContext): Scheduler

    Permalink

    Scheduler builder.

    Scheduler builder.

    executor

    is the ScheduledExecutorService that handles the scheduling of tasks into the future.

    ec

    is the execution context in which all tasks will run.

    Definition Classes
    SchedulerCompanion
  10. def apply(executor: ScheduledExecutorService, ec: ExecutionContext, r: UncaughtExceptionReporter): Scheduler

    Permalink

    Scheduler builder.

    Scheduler builder.

    executor

    is the ScheduledExecutorService that handles the scheduling of tasks into the future.

    ec

    is the execution context in which all tasks will run.

    r

    is the UncaughtExceptionReporter that logs uncaught exceptions.

    Definition Classes
    SchedulerCompanion
  11. final def asInstanceOf[T0]: T0

    Permalink
    Definition Classes
    Any
  12. def clone(): AnyRef

    Permalink
    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  13. def computation(parallelism: Int, r: UncaughtExceptionReporter = LogExceptionsToStandardErr): Scheduler

    Permalink

    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

    parallelism

    is the number of threads that can run in parallel

    r

    is the UncaughtExceptionReporter that logs uncaught exceptions.

    Definition Classes
    SchedulerCompanion
  14. final def eq(arg0: AnyRef): Boolean

    Permalink
    Definition Classes
    AnyRef
  15. def equals(arg0: Any): Boolean

    Permalink
    Definition Classes
    AnyRef → Any
  16. def finalize(): Unit

    Permalink
    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( classOf[java.lang.Throwable] )
  17. def fixedPool(name: String, poolSize: Int, daemonic: Boolean = true, r: UncaughtExceptionReporter = LogExceptionsToStandardErr): Scheduler

    Permalink

    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

    is the name of the created thread, for easy identification

    daemonic

    specifies whether the created thread should be daemonic

    r

    is the UncaughtExceptionReporter that logs uncaught exceptions.

    Definition Classes
    SchedulerCompanion
  18. final def getClass(): Class[_]

    Permalink
    Definition Classes
    AnyRef → Any
  19. def hashCode(): Int

    Permalink
    Definition Classes
    AnyRef → Any
  20. def io(name: String = "monifu-io", daemonic: Boolean = true, r: UncaughtExceptionReporter = LogExceptionsToStandardErr): Scheduler

    Permalink

    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

    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).

    r

    is the UncaughtExceptionReporter that logs uncaught exceptions.

    Definition Classes
    SchedulerCompanion
  21. final def isInstanceOf[T0]: Boolean

    Permalink
    Definition Classes
    Any
  22. final def ne(arg0: AnyRef): Boolean

    Permalink
    Definition Classes
    AnyRef
  23. final def notify(): Unit

    Permalink
    Definition Classes
    AnyRef
  24. final def notifyAll(): Unit

    Permalink
    Definition Classes
    AnyRef
  25. def singleThread(name: String, daemonic: Boolean = true, r: UncaughtExceptionReporter = LogExceptionsToStandardErr): Scheduler

    Permalink

    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

    r

    is the UncaughtExceptionReporter that logs uncaught exceptions.

    Definition Classes
    SchedulerCompanion
  26. final def synchronized[T0](arg0: ⇒ T0): T0

    Permalink
    Definition Classes
    AnyRef
  27. def toString(): String

    Permalink
    Definition Classes
    AnyRef → Any
  28. final def wait(): Unit

    Permalink
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  29. final def wait(arg0: Long, arg1: Int): Unit

    Permalink
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  30. final def wait(arg0: Long): Unit

    Permalink
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )

Inherited from SchedulerCompanion

Inherited from AnyRef

Inherited from Any

Ungrouped