|
/* Title: Pure/Concurrent/mailbox.scala
Author: Makarius
Message exchange via mailbox, with multiple senders (non-blocking,
unbounded buffering) and single receiver (bulk messages).
*/
package isabelle
object Mailbox
{
def apply[A]: Mailbox[A] = new Mailbox[A]()
}
class Mailbox[A] private()
{
private val mailbox = Synchronized[List[A]](Nil)
override def toString: String = mailbox.value.reverse.mkString("Mailbox(", ",", ")")
def send(msg: A): Unit = mailbox.change(msg :: _)
def receive(timeout: Option[Time] = None): List[A] =
(mailbox.timed_access(_ => timeout.map(t => Time.now() + t),
{ case Nil => None case msgs => Some((msgs, Nil)) }) getOrElse Nil).reverse
def await_empty: Unit =
mailbox.guarded_access({ case Nil => Some(((), Nil)) case _ => None })
}
¤ Dauer der Verarbeitung: 0.14 Sekunden
(vorverarbeitet)
¤
|
Haftungshinweis
Die Informationen auf dieser Webseite wurden
nach bestem Wissen sorgfältig zusammengestellt. Es wird jedoch weder Vollständigkeit, noch Richtigkeit,
noch Qualität der bereit gestellten Informationen zugesichert.
Bemerkung:
Die farbliche Syntaxdarstellung ist noch experimentell.
|
