final
class
DeadlineWaitQueue extends AnyRef
Instance Constructors
-
new
DeadlineWaitQueue(timer: Timer)
Type Members
-
case class
Waiter(timerTask: TimerTask, awaken: () ⇒ Unit, timeout: () ⇒ Unit) extends Product with Serializable
Value Members
-
final
def
!=(arg0: AnyRef): Boolean
-
final
def
!=(arg0: Any): Boolean
-
final
def
##(): Int
-
final
def
==(arg0: AnyRef): Boolean
-
final
def
==(arg0: Any): Boolean
-
def
add(deadline: Time, awaken: () ⇒ Unit, timeout: () ⇒ Unit): Waiter
-
final
def
asInstanceOf[T0]: T0
-
def
clone(): AnyRef
-
final
def
eq(arg0: AnyRef): Boolean
-
def
equals(arg0: Any): Boolean
-
def
evictAll(): Unit
-
def
finalize(): Unit
-
final
def
getClass(): java.lang.Class[_]
-
def
hashCode(): Int
-
final
def
isInstanceOf[T0]: Boolean
-
final
def
ne(arg0: AnyRef): Boolean
-
final
def
notify(): Unit
-
final
def
notifyAll(): Unit
-
def
remove(waiter: Waiter): Unit
-
def
size(): Int
-
final
def
synchronized[T0](arg0: ⇒ T0): T0
-
def
toString(): String
-
def
trigger(): Unit
-
def
triggerAll(): Unit
-
final
def
wait(): Unit
-
final
def
wait(arg0: Long, arg1: Int): Unit
-
final
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.