@@ -207,44 +207,44 @@ public void TestBgLong() {
207
207
[ Test ]
208
208
public void TestDoubleBg ( ) {
209
209
SharedQueue q = new SharedQueue ( ) ;
210
- EnqueueAfter ( 50 , q , 123 ) ;
211
- EnqueueAfter ( 100 , q , 234 ) ;
210
+ EnqueueAfter ( 100 , q , 123 ) ;
211
+ EnqueueAfter ( 200 , q , 234 ) ;
212
212
213
213
ResetTimer ( ) ;
214
214
object v ;
215
215
bool r ;
216
216
217
- r = q . Dequeue ( 100 , out v ) ;
218
- Assert . Greater ( ElapsedMs ( ) , 40 ) ;
219
- Assert . Greater ( 60 , ElapsedMs ( ) ) ;
217
+ r = q . Dequeue ( 200 , out v ) ;
218
+ Assert . Greater ( ElapsedMs ( ) , 80 ) ;
219
+ Assert . Greater ( 120 , ElapsedMs ( ) ) ;
220
220
Assert . IsTrue ( r ) ;
221
221
Assert . AreEqual ( 123 , v ) ;
222
222
223
- r = q . Dequeue ( 100 , out v ) ;
224
- Assert . Greater ( ElapsedMs ( ) , 90 ) ;
225
- Assert . Greater ( 110 , ElapsedMs ( ) ) ;
223
+ r = q . Dequeue ( 200 , out v ) ;
224
+ Assert . Greater ( ElapsedMs ( ) , 180 ) ;
225
+ Assert . Greater ( 220 , ElapsedMs ( ) ) ;
226
226
Assert . IsTrue ( r ) ;
227
227
Assert . AreEqual ( 234 , v ) ;
228
228
}
229
229
230
230
[ Test ]
231
231
public void TestDoublePoll ( ) {
232
232
SharedQueue q = new SharedQueue ( ) ;
233
- EnqueueAfter ( 50 , q , 123 ) ;
233
+ EnqueueAfter ( 100 , q , 123 ) ;
234
234
235
235
ResetTimer ( ) ;
236
236
object v ;
237
237
bool r ;
238
238
239
- r = q . Dequeue ( 25 , out v ) ;
240
- Assert . Greater ( ElapsedMs ( ) , 15 ) ;
241
- Assert . Greater ( 35 , ElapsedMs ( ) ) ;
239
+ r = q . Dequeue ( 50 , out v ) ;
240
+ Assert . Greater ( ElapsedMs ( ) , 30 ) ;
241
+ Assert . Greater ( 70 , ElapsedMs ( ) ) ;
242
242
Assert . IsTrue ( ! r ) ;
243
243
Assert . AreEqual ( null , v ) ;
244
244
245
- r = q . Dequeue ( 50 , out v ) ;
246
- Assert . Greater ( ElapsedMs ( ) , 40 ) ;
247
- Assert . Greater ( 60 , ElapsedMs ( ) ) ;
245
+ r = q . Dequeue ( 100 , out v ) ;
246
+ Assert . Greater ( ElapsedMs ( ) , 80 ) ;
247
+ Assert . Greater ( 120 , ElapsedMs ( ) ) ;
248
248
Assert . IsTrue ( r ) ;
249
249
Assert . AreEqual ( 123 , v ) ;
250
250
}
0 commit comments