csharp/test/Ice/hold/Timer.cs


1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123

//
// Copyright (c) ZeroC, Inc. All rights reserved.
//

using System;
using System.Diagnostics;
using System.Collections.Generic;
using System.Threading;

//
// TODO replace with System.Timers.Timer
//
namespace Ice
{
    namespace hold
    {
        public class Timer
        {
            public delegate void Task();

            private class Entry : IComparable<Entry>
            {
                public Task task;
                public long when;

                public int CompareTo(Entry e)
                {
                    if(when < e.when)
                    {
                        return -1;
                    }
                    else if(when == e.when)
                    {
                        return 0;
                    }
                    else
                    {
                        return 1;
                    }
                }
            };

            public Timer()
            {
                _t = new Thread(new ThreadStart(run));
                _t.Start();
            }

            public void schedule(Task task, int milliseconds)
            {
                lock(this)
                {
                    Entry e = new Entry();
                    e.task = task;
                    e.when = currentMonotonicTimeMillis() + milliseconds;
                    _tasks.Add(e);
                    _tasks.Sort();
                    Monitor.Pulse(this);
                }
            }

            public void shutdown()
            {
                lock(this)
                {
                    Entry e = new Entry();
                    e.task = null;
                    e.when = 0;
                    _tasks.Add(e);
                    _tasks.Sort();
                    Monitor.Pulse(this);
                }
            }

            public void waitForShutdown()
            {
                _t.Join();
            }

            private void run()
            {
                while(true)
                {
                    Entry e;
                    lock(this)
                    {
                        while(true)
                        {
                            while(_tasks.Count == 0)
                            {
                                Monitor.Wait(this);
                            }

                            e = _tasks[0];
                            if(e.task == null)
                            {
                                return;
                            }
                            long now = currentMonotonicTimeMillis();
                            if(now >= e.when)
                            {
                                _tasks.RemoveAt(0);
                                break;
                            }
                            Monitor.Wait(this,(int)(e.when - now));
                        }
                    }
                    e.task();
                }

            }

            private long currentMonotonicTimeMillis()
            {
                return _sw.ElapsedMilliseconds;
            }
            private Stopwatch _sw = Stopwatch.StartNew();

            private Thread _t;
            private List<Entry> _tasks = new List<Entry>();
        }
    }
}