trait ScheduledExecutionContext extends AnyRef
A trait for scheduling delayed or periodic tasks
- Alphabetic
- By Inheritance
- ScheduledExecutionContext
- AnyRef
- Any
- Hide All
- Show All
- Public
- All
Abstract Value Members
-
abstract
def
reportFailure(cause: Throwable): Unit
Report a failure.
Report a failure. Used to report failures during periodic tasks
-
abstract
def
schedule[A](delay: FiniteDuration)(f: ⇒ A): DelayedFuture[A]
Create a DelayedFuture that executes the supplied function after the given delay
Create a DelayedFuture that executes the supplied function after the given delay
- delay
the time from now to delay execution
- f
the function to execute
- returns
a DelayedFuture that can be used to extract result
- Exceptions thrown
java.util.concurrent.RejectedExecutionException
if the task cannot be scheduled for execution
-
abstract
def
scheduleAtFixedRate[U](initialDelay: FiniteDuration, period: FiniteDuration, paused: Boolean = false)(task: () ⇒ U): PeriodicTask
Creates a PeriodicTask that executes first after the given initial delay, and subsequently with the given period.
Creates a PeriodicTask that executes first after the given initial delay, and subsequently with the given period. PeriodicTask may stopped using the cancel method. If a failure occurs while processing the task, the task is automatically cancelled. If any execution of this task takes longer than its period, then subsequent executions may start late, but will not concurrently execute.
- initialDelay
the time to delay first execution
- period
the period between successive executions
- paused
TRUE to start the periodic task paused FALSE to start running
- task
the task to execute
- returns
a PeriodicTask
- Exceptions thrown
java.lang.IllegalArgumentException
if period less than or equal to zerojava.util.concurrent.RejectedExecutionException
if the task cannot be scheduled for execution
-
abstract
def
scheduleCancellable[A](delay: FiniteDuration, fallback: ⇒ A)(f: ⇒ A): CancellableDelayedFuture[A]
Create a DelayedFuture that executes the supplied function after the given delay
Create a DelayedFuture that executes the supplied function after the given delay
- delay
the time from now to delay execution
- fallback
the value to return if the future is cancelled
- f
the function to execute
- returns
a DelayedFuture that can be used to extract result or cancel (only before it has been started)
- Exceptions thrown
java.util.concurrent.RejectedExecutionException
if the task cannot be scheduled for execution
Concrete Value Members
-
final
def
!=(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
final
def
##(): Int
- Definition Classes
- AnyRef → Any
-
final
def
==(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
final
def
asInstanceOf[T0]: T0
- Definition Classes
- Any
-
def
clone(): AnyRef
- Attributes
- protected[java.lang]
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
final
def
eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
def
equals(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
def
finalize(): Unit
- Attributes
- protected[java.lang]
- Definition Classes
- AnyRef
- Annotations
- @throws( classOf[java.lang.Throwable] )
-
final
def
getClass(): Class[_]
- Definition Classes
- AnyRef → Any
-
def
hashCode(): Int
- Definition Classes
- AnyRef → Any
-
final
def
isInstanceOf[T0]: Boolean
- Definition Classes
- Any
-
final
def
ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
final
def
notify(): Unit
- Definition Classes
- AnyRef
-
final
def
notifyAll(): Unit
- Definition Classes
- AnyRef
-
final
def
synchronized[T0](arg0: ⇒ T0): T0
- Definition Classes
- AnyRef
-
def
toString(): String
- Definition Classes
- AnyRef → Any
-
final
def
wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
final
def
wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
final
def
wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )