blob: e818c9f80502fe888a64b5cec50e6babeb260f90 (
plain)
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
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
|
// **********************************************************************
//
// Copyright (c) 2003-2014 ZeroC, Inc. All rights reserved.
//
// This copy of Ice is licensed to you under the terms described in the
// ICE_LICENSE file included in this distribution.
//
// **********************************************************************
using System;
using System.Threading;
using System.Collections;
using Demo;
public class WorkQueue
{
private class CallbackEntry
{
public AMD_Hello_sayHello cb;
public int delay;
}
public void Join()
{
thread_.Join();
}
public void Start()
{
thread_ = new Thread(new ThreadStart(Run));
thread_.Start();
}
public void Run()
{
#if COMPACT
_m.Lock();
try
#else
lock(this)
#endif
{
while(!_done)
{
if(_callbacks.Count == 0)
{
#if COMPACT
_m.Wait();
#else
Monitor.Wait(this);
#endif
}
if(_callbacks.Count != 0)
{
//
// Get next work item.
//
CallbackEntry entry = (CallbackEntry)_callbacks[0];
//
// Wait for the amount of time indicated in delay to
// emulate a process that takes a significant period of
// time to complete.
//
#if COMPACT
_m.TimedWait(entry.delay);
#else
Monitor.Wait(this, entry.delay);
#endif
if(!_done)
{
//
// Print greeting and send response.
//
_callbacks.RemoveAt(0);
Console.Out.WriteLine("Belated Hello World!");
entry.cb.ice_response();
}
}
}
foreach(CallbackEntry e in _callbacks)
{
e.cb.ice_exception(new RequestCanceledException());
}
}
#if COMPACT
finally
{
_m.Unlock();
}
#endif
}
public void Add(AMD_Hello_sayHello cb, int delay)
{
#if COMPACT
_m.Lock();
try
#else
lock(this)
#endif
{
if(!_done)
{
//
// Add the work item.
//
CallbackEntry entry = new CallbackEntry();
entry.cb = cb;
entry.delay = delay;
if(_callbacks.Count == 0)
{
#if COMPACT
_m.Notify();
#else
Monitor.Pulse(this);
#endif
}
_callbacks.Add(entry);
}
else
{
//
// Destroyed, throw exception.
//
cb.ice_exception(new RequestCanceledException());
}
}
#if COMPACT
finally
{
_m.Unlock();
}
#endif
}
public void destroy()
{
#if COMPACT
_m.Lock();
try
{
_done = true;
_m.Notify();
}
finally
{
_m.Unlock();
}
#else
lock(this)
{
_done = true;
Monitor.Pulse(this);
}
#endif
}
private ArrayList _callbacks = new ArrayList();
private bool _done = false;
private Thread thread_;
#if COMPACT
private readonly IceUtilInternal.Monitor _m = new IceUtilInternal.Monitor();
#endif
}
|
