@@ -78,11 +78,11 @@ public void Run()
78
78
}
79
79
80
80
public static void EnqueueAfter ( int delayMs , SharedQueue q , object v ) {
81
- DelayedEnqueuer de = new DelayedEnqueuer ( ) ;
82
- de . m_q = q ;
83
- de . m_delayMs = delayMs ;
84
- de . m_v = v ;
85
- new Thread ( new ThreadStart ( de . Run ) ) . Start ( ) ;
81
+ DelayedEnqueuer de = new DelayedEnqueuer ( ) ;
82
+ de . m_q = q ;
83
+ de . m_delayMs = delayMs ;
84
+ de . m_v = v ;
85
+ new Thread ( new ThreadStart ( de . Run ) ) . Start ( ) ;
86
86
}
87
87
88
88
public DateTime m_startTime ;
@@ -119,133 +119,133 @@ public void TestDequeueNoWait3() {
119
119
120
120
[ Test ]
121
121
public void TestDelayedEnqueue ( ) {
122
- SharedQueue q = new SharedQueue ( ) ;
123
- ResetTimer ( ) ;
124
- EnqueueAfter ( 50 , q , 1 ) ;
125
- Assert . AreEqual ( 0 , q . DequeueNoWait ( 0 ) ) ;
126
- Assert . Greater ( 45 , ElapsedMs ( ) ) ;
127
- Assert . AreEqual ( 1 , q . Dequeue ( ) ) ;
128
- Assert . Greater ( ElapsedMs ( ) , 45 ) ;
122
+ SharedQueue q = new SharedQueue ( ) ;
123
+ ResetTimer ( ) ;
124
+ EnqueueAfter ( 50 , q , 1 ) ;
125
+ Assert . AreEqual ( 0 , q . DequeueNoWait ( 0 ) ) ;
126
+ Assert . Greater ( 45 , ElapsedMs ( ) ) ;
127
+ Assert . AreEqual ( 1 , q . Dequeue ( ) ) ;
128
+ Assert . Greater ( ElapsedMs ( ) , 45 ) ;
129
129
}
130
130
131
131
[ Test ]
132
132
public void TestTimeoutShort ( ) {
133
- SharedQueue q = new SharedQueue ( ) ;
134
- q . Enqueue ( 123 ) ;
133
+ SharedQueue q = new SharedQueue ( ) ;
134
+ q . Enqueue ( 123 ) ;
135
135
136
- ResetTimer ( ) ;
137
- object v ;
138
- bool r = q . Dequeue ( 250 , out v ) ;
139
- Assert . Greater ( 50 , ElapsedMs ( ) ) ;
140
- Assert . IsTrue ( r ) ;
141
- Assert . AreEqual ( 123 , v ) ;
136
+ ResetTimer ( ) ;
137
+ object v ;
138
+ bool r = q . Dequeue ( 250 , out v ) ;
139
+ Assert . Greater ( 50 , ElapsedMs ( ) ) ;
140
+ Assert . IsTrue ( r ) ;
141
+ Assert . AreEqual ( 123 , v ) ;
142
142
}
143
143
144
144
[ Test ]
145
145
public void TestTimeoutLong ( ) {
146
- SharedQueue q = new SharedQueue ( ) ;
146
+ SharedQueue q = new SharedQueue ( ) ;
147
147
148
- ResetTimer ( ) ;
149
- object v ;
150
- bool r = q . Dequeue ( 250 , out v ) ;
151
- Assert . Greater ( ElapsedMs ( ) , 200 ) ;
152
- Assert . IsTrue ( ! r ) ;
153
- Assert . AreEqual ( null , v ) ;
148
+ ResetTimer ( ) ;
149
+ object v ;
150
+ bool r = q . Dequeue ( 250 , out v ) ;
151
+ Assert . Greater ( ElapsedMs ( ) , 200 ) ;
152
+ Assert . IsTrue ( ! r ) ;
153
+ Assert . AreEqual ( null , v ) ;
154
154
}
155
155
156
156
[ Test ]
157
157
public void TestTimeoutNegative ( ) {
158
- SharedQueue q = new SharedQueue ( ) ;
158
+ SharedQueue q = new SharedQueue ( ) ;
159
159
160
- ResetTimer ( ) ;
161
- object v ;
162
- bool r = q . Dequeue ( - 10000 , out v ) ;
163
- Assert . Greater ( 50 , ElapsedMs ( ) ) ;
164
- Assert . IsTrue ( ! r ) ;
165
- Assert . AreEqual ( null , v ) ;
160
+ ResetTimer ( ) ;
161
+ object v ;
162
+ bool r = q . Dequeue ( - 10000 , out v ) ;
163
+ Assert . Greater ( 50 , ElapsedMs ( ) ) ;
164
+ Assert . IsTrue ( ! r ) ;
165
+ Assert . AreEqual ( null , v ) ;
166
166
}
167
167
168
168
[ Test ]
169
169
public void TestTimeoutInfinite ( ) {
170
- SharedQueue q = new SharedQueue ( ) ;
171
- EnqueueAfter ( 250 , q , 123 ) ;
170
+ SharedQueue q = new SharedQueue ( ) ;
171
+ EnqueueAfter ( 250 , q , 123 ) ;
172
172
173
- ResetTimer ( ) ;
174
- object v ;
175
- bool r = q . Dequeue ( Timeout . Infinite , out v ) ;
176
- Assert . Greater ( ElapsedMs ( ) , 200 ) ;
177
- Assert . IsTrue ( r ) ;
178
- Assert . AreEqual ( 123 , v ) ;
173
+ ResetTimer ( ) ;
174
+ object v ;
175
+ bool r = q . Dequeue ( Timeout . Infinite , out v ) ;
176
+ Assert . Greater ( ElapsedMs ( ) , 200 ) ;
177
+ Assert . IsTrue ( r ) ;
178
+ Assert . AreEqual ( 123 , v ) ;
179
179
}
180
180
181
181
[ Test ]
182
182
public void TestBgShort ( ) {
183
- SharedQueue q = new SharedQueue ( ) ;
184
- EnqueueAfter ( 50 , q , 123 ) ;
183
+ SharedQueue q = new SharedQueue ( ) ;
184
+ EnqueueAfter ( 50 , q , 123 ) ;
185
185
186
- ResetTimer ( ) ;
187
- object v ;
188
- bool r = q . Dequeue ( 100 , out v ) ;
189
- Assert . Greater ( ElapsedMs ( ) , 40 ) ;
190
- Assert . IsTrue ( r ) ;
191
- Assert . AreEqual ( 123 , v ) ;
186
+ ResetTimer ( ) ;
187
+ object v ;
188
+ bool r = q . Dequeue ( 100 , out v ) ;
189
+ Assert . Greater ( ElapsedMs ( ) , 40 ) ;
190
+ Assert . IsTrue ( r ) ;
191
+ Assert . AreEqual ( 123 , v ) ;
192
192
}
193
193
194
194
[ Test ]
195
195
public void TestBgLong ( ) {
196
- SharedQueue q = new SharedQueue ( ) ;
197
- EnqueueAfter ( 150 , q , 123 ) ;
196
+ SharedQueue q = new SharedQueue ( ) ;
197
+ EnqueueAfter ( 150 , q , 123 ) ;
198
198
199
- ResetTimer ( ) ;
200
- object v ;
201
- bool r = q . Dequeue ( 100 , out v ) ;
202
- Assert . Greater ( 110 , ElapsedMs ( ) ) ;
203
- Assert . IsTrue ( ! r ) ;
204
- Assert . AreEqual ( null , v ) ;
199
+ ResetTimer ( ) ;
200
+ object v ;
201
+ bool r = q . Dequeue ( 100 , out v ) ;
202
+ Assert . Greater ( 110 , ElapsedMs ( ) ) ;
203
+ Assert . IsTrue ( ! r ) ;
204
+ Assert . AreEqual ( null , v ) ;
205
205
}
206
206
207
207
[ Test ]
208
208
public void TestDoubleBg ( ) {
209
- SharedQueue q = new SharedQueue ( ) ;
210
- EnqueueAfter ( 50 , q , 123 ) ;
211
- EnqueueAfter ( 100 , q , 234 ) ;
209
+ SharedQueue q = new SharedQueue ( ) ;
210
+ EnqueueAfter ( 50 , q , 123 ) ;
211
+ EnqueueAfter ( 100 , q , 234 ) ;
212
212
213
- ResetTimer ( ) ;
214
- object v ;
215
- bool r ;
213
+ ResetTimer ( ) ;
214
+ object v ;
215
+ bool r ;
216
216
217
- r = q . Dequeue ( 100 , out v ) ;
218
- Assert . Greater ( ElapsedMs ( ) , 40 ) ;
219
- Assert . Greater ( 60 , ElapsedMs ( ) ) ;
220
- Assert . IsTrue ( r ) ;
221
- Assert . AreEqual ( 123 , v ) ;
217
+ r = q . Dequeue ( 100 , out v ) ;
218
+ Assert . Greater ( ElapsedMs ( ) , 40 ) ;
219
+ Assert . Greater ( 60 , ElapsedMs ( ) ) ;
220
+ Assert . IsTrue ( r ) ;
221
+ Assert . AreEqual ( 123 , v ) ;
222
222
223
- r = q . Dequeue ( 100 , out v ) ;
224
- Assert . Greater ( ElapsedMs ( ) , 90 ) ;
225
- Assert . Greater ( 110 , ElapsedMs ( ) ) ;
226
- Assert . IsTrue ( r ) ;
227
- Assert . AreEqual ( 234 , v ) ;
223
+ r = q . Dequeue ( 100 , out v ) ;
224
+ Assert . Greater ( ElapsedMs ( ) , 90 ) ;
225
+ Assert . Greater ( 110 , ElapsedMs ( ) ) ;
226
+ Assert . IsTrue ( r ) ;
227
+ Assert . AreEqual ( 234 , v ) ;
228
228
}
229
229
230
230
[ Test ]
231
231
public void TestDoublePoll ( ) {
232
- SharedQueue q = new SharedQueue ( ) ;
233
- EnqueueAfter ( 50 , q , 123 ) ;
234
-
235
- ResetTimer ( ) ;
236
- object v ;
237
- bool r ;
238
-
239
- r = q . Dequeue ( 25 , out v ) ;
240
- Assert . Greater ( ElapsedMs ( ) , 15 ) ;
241
- Assert . Greater ( 35 , ElapsedMs ( ) ) ;
242
- Assert . IsTrue ( ! r ) ;
243
- Assert . AreEqual ( null , v ) ;
244
-
245
- r = q . Dequeue ( 50 , out v ) ;
246
- Assert . Greater ( ElapsedMs ( ) , 40 ) ;
247
- Assert . Greater ( 60 , ElapsedMs ( ) ) ;
248
- Assert . IsTrue ( r ) ;
249
- Assert . AreEqual ( 123 , v ) ;
232
+ SharedQueue q = new SharedQueue ( ) ;
233
+ EnqueueAfter ( 50 , q , 123 ) ;
234
+
235
+ ResetTimer ( ) ;
236
+ object v ;
237
+ bool r ;
238
+
239
+ r = q . Dequeue ( 25 , out v ) ;
240
+ Assert . Greater ( ElapsedMs ( ) , 15 ) ;
241
+ Assert . Greater ( 35 , ElapsedMs ( ) ) ;
242
+ Assert . IsTrue ( ! r ) ;
243
+ Assert . AreEqual ( null , v ) ;
244
+
245
+ r = q . Dequeue ( 50 , out v ) ;
246
+ Assert . Greater ( ElapsedMs ( ) , 40 ) ;
247
+ Assert . Greater ( 60 , ElapsedMs ( ) ) ;
248
+ Assert . IsTrue ( r ) ;
249
+ Assert . AreEqual ( 123 , v ) ;
250
250
}
251
251
}
0 commit comments