versaplexd/vxevent.cs

   1 using System;
   2
   3 public enum EventContext {
   4     MainThread,
   5     ThreadPool
   6 }
   7
   8 public interface IVxEvent {
   9     void Run();
  10
  11     EventContext Context {
  12         get;
  13     }
  14 }
  15
  16 public interface IFutureVxEvent : IVxEvent, IComparable {
  17     DateTime When {
  18         get;
  19     }
  20 }
  21
  22 public delegate void EmptyCallback();
  23 public delegate void SingleArgCallback(object arg);
  24
  25 public class VxEvent : IVxEvent {
  26     private readonly EmptyCallback cb;
  27
  28     public VxEvent(EmptyCallback cb)
  29     {
  30         this.cb = cb;
  31     }
  32
  33     public void Run()
  34     {
  35         cb();
  36     }
  37
  38     public EventContext Context {
  39         get { return EventContext.MainThread; }
  40     }
  41 }
  42
  43 public class ArgVxEvent : IVxEvent {
  44     private readonly SingleArgCallback cb;
  45     private readonly object arg;
  46
  47     public ArgVxEvent(SingleArgCallback cb, object arg)
  48     {
  49         this.cb = cb;
  50         this.arg = arg;
  51     }
  52
  53     public void Run()
  54     {
  55         cb(arg);
  56     }
  57
  58     public EventContext Context {
  59         get { return EventContext.MainThread; }
  60     }
  61 }
  62
  63 public class FutureVxEvent : VxEvent, IFutureVxEvent {
  64     private readonly DateTime when;
  65
  66     public FutureVxEvent(EmptyCallback cb, DateTime when) : base(cb)
  67     {
  68         this.when = when;
  69     }
  70
  71     public FutureVxEvent(EmptyCallback cb, TimeSpan delta) : base(cb)
  72     {
  73         this.when = DateTime.Now + delta;
  74     }
  75
  76     public DateTime When {
  77         get { return when; }
  78     }
  79
  80     public int CompareTo(object other)
  81     {
  82         if (!(other is IFutureVxEvent)) {
  83             throw new ArgumentException("Other is not an IFutureVxEvent");
  84         }
  85
  86         IFutureVxEvent o = (IFutureVxEvent)other;
  87         return when.CompareTo(o.When);
  88     }
  89 }
  90
  91 public class ArgFutureVxEvent : ArgVxEvent, IFutureVxEvent {
  92     private readonly DateTime when;
  93
  94     public ArgFutureVxEvent(SingleArgCallback cb, object arg, DateTime when)
  95         : base(cb, arg)
  96     {
  97         this.when = when;
  98     }
  99
 100     public ArgFutureVxEvent(SingleArgCallback cb, object arg, TimeSpan delta)
 101         : base(cb, arg)
 102     {
 103         this.when = DateTime.Now + delta;
 104     }
 105
 106     public DateTime When {
 107         get { return when; }
 108     }
 109
 110     public int CompareTo(object other)
 111     {
 112         if (!(other is IFutureVxEvent)) {
 113             throw new ArgumentException("Other is not an IFutureVxEvent");
 114         }
 115
 116         IFutureVxEvent o = (IFutureVxEvent)other;
 117         return when.CompareTo(o.When);
 118     }
 119 }