| 
56768
 | 
     1  | 
/*  Title:      Pure/Concurrent/event_timer.scala
  | 
| 
 | 
     2  | 
    Author:     Makarius
  | 
| 
 | 
     3  | 
  | 
| 
 | 
     4  | 
Initiate event after given point in time.
  | 
| 
 | 
     5  | 
  | 
| 
 | 
     6  | 
Note: events are run as synchronized action within a dedicated thread
  | 
| 
 | 
     7  | 
and should finish quickly without further ado.
  | 
| 
 | 
     8  | 
*/
  | 
| 
 | 
     9  | 
  | 
| 
 | 
    10  | 
package isabelle
  | 
| 
 | 
    11  | 
  | 
| 
 | 
    12  | 
  | 
| 
64056
 | 
    13  | 
import java.util.{Timer, TimerTask, Date => JDate}
 | 
| 
56768
 | 
    14  | 
  | 
| 
 | 
    15  | 
  | 
| 
75393
 | 
    16  | 
object Event_Timer {
 | 
| 
56768
 | 
    17  | 
  private lazy val event_timer = new Timer("event_timer", true)
 | 
| 
 | 
    18  | 
  | 
| 
75393
 | 
    19  | 
  final class Request private[Event_Timer](
  | 
| 
 | 
    20  | 
    val time: Time,
  | 
| 
 | 
    21  | 
    val repeat: Option[Time],
  | 
| 
 | 
    22  | 
    task: TimerTask
  | 
| 
 | 
    23  | 
  ) {
 | 
| 
73367
 | 
    24  | 
    def cancel(): Boolean = task.cancel()
  | 
| 
56768
 | 
    25  | 
  }
  | 
| 
 | 
    26  | 
  | 
| 
75393
 | 
    27  | 
  def request(time: Time, repeat: Option[Time] = None)(event: => Unit): Request = {
 | 
| 
73340
 | 
    28  | 
    val task = new TimerTask { def run: Unit = event }
 | 
| 
67890
 | 
    29  | 
    repeat match {
 | 
| 
 | 
    30  | 
      case None => event_timer.schedule(task, new JDate(time.ms))
  | 
| 
 | 
    31  | 
      case Some(rep) => event_timer.schedule(task, new JDate(time.ms), rep.ms)
  | 
| 
 | 
    32  | 
    }
  | 
| 
 | 
    33  | 
    new Request(time, repeat, task)
  | 
| 
56768
 | 
    34  | 
  }
  | 
| 
 | 
    35  | 
}
  |