class
DeadlineWaitQueue
extends AnyRef
Instance Constructors
-
new
DeadlineWaitQueue
(timer: Timer)
Type Members
-
case class
Waiter
(timerTask: TimerTask, awaken: () ⇒ Unit) extends Product with Serializable
Value Members
-
def
!=
(arg0: AnyRef): Boolean
-
def
!=
(arg0: Any): Boolean
-
def
##
(): Int
-
def
==
(arg0: AnyRef): Boolean
-
def
==
(arg0: Any): Boolean
-
def
add
(deadline: Time, awaken: () ⇒ Unit, onTimeout: () ⇒ Unit): Waiter
-
def
asInstanceOf
[T0]
: T0
-
def
clone
(): AnyRef
-
def
eq
(arg0: AnyRef): Boolean
-
def
equals
(arg0: Any): Boolean
-
def
finalize
(): Unit
-
def
getClass
(): java.lang.Class[_]
-
def
hashCode
(): Int
-
def
isInstanceOf
[T0]
: Boolean
-
def
ne
(arg0: AnyRef): Boolean
-
def
notify
(): Unit
-
def
notifyAll
(): Unit
-
def
remove
(waiter: Waiter): Unit
-
def
size
(): Int
-
def
synchronized
[T0]
(arg0: ⇒ T0): T0
-
def
toString
(): String
-
def
trigger
(): Unit
-
def
triggerAll
(): Unit
-
def
wait
(): Unit
-
def
wait
(arg0: Long, arg1: Int): Unit
-
def
wait
(arg0: Long): Unit
Inherited from AnyRef
Inherited from Any
A wait queue where each item has a timeout. On each
trigger()
, one waiter is awoken (the awaken function is called). If the timeout is triggered by the Timer, the timeout function will be called instead. The queue promises that exactly one of the functions will be called, never both.