318 |
|
/** |
319 |
|
* put(null) throws NPE |
320 |
|
*/ |
321 |
< |
public void testPutNull() { |
321 |
> |
public void testPutNull() { |
322 |
|
try { |
323 |
|
DelayQueue q = new DelayQueue(); |
324 |
|
q.put(null); |
325 |
|
shouldThrow(); |
326 |
|
} catch (NullPointerException success) {} |
327 |
< |
} |
327 |
> |
} |
328 |
|
|
329 |
|
/** |
330 |
|
* all elements successfully put are contained |
331 |
|
*/ |
332 |
< |
public void testPut() { |
333 |
< |
DelayQueue q = new DelayQueue(); |
334 |
< |
for (int i = 0; i < SIZE; ++i) { |
335 |
< |
PDelay I = new PDelay(i); |
336 |
< |
q.put(I); |
337 |
< |
assertTrue(q.contains(I)); |
338 |
< |
} |
339 |
< |
assertEquals(SIZE, q.size()); |
332 |
> |
public void testPut() { |
333 |
> |
DelayQueue q = new DelayQueue(); |
334 |
> |
for (int i = 0; i < SIZE; ++i) { |
335 |
> |
PDelay I = new PDelay(i); |
336 |
> |
q.put(I); |
337 |
> |
assertTrue(q.contains(I)); |
338 |
> |
} |
339 |
> |
assertEquals(SIZE, q.size()); |
340 |
|
} |
341 |
|
|
342 |
|
/** |
353 |
|
}}); |
354 |
|
|
355 |
|
t.start(); |
356 |
< |
Thread.sleep(SHORT_DELAY_MS); |
356 |
> |
delay(SHORT_DELAY_MS); |
357 |
|
q.take(); |
358 |
|
t.interrupt(); |
359 |
|
t.join(); |
373 |
|
}}); |
374 |
|
|
375 |
|
t.start(); |
376 |
< |
Thread.sleep(SMALL_DELAY_MS); |
376 |
> |
delay(SMALL_DELAY_MS); |
377 |
|
t.interrupt(); |
378 |
|
t.join(); |
379 |
|
} |
406 |
|
assertTrue(millisElapsedSince(t0) >= SHORT_DELAY_MS); |
407 |
|
}}); |
408 |
|
threadStarted.await(); |
409 |
< |
Thread.sleep(SHORT_DELAY_MS); |
409 |
> |
delay(SHORT_DELAY_MS); |
410 |
|
assertTrue(t.isAlive()); |
411 |
|
t.interrupt(); |
412 |
|
awaitTermination(t, MEDIUM_DELAY_MS); |
430 |
|
}}); |
431 |
|
|
432 |
|
t.start(); |
433 |
< |
Thread.sleep(SHORT_DELAY_MS); |
433 |
> |
delay(SHORT_DELAY_MS); |
434 |
|
t.interrupt(); |
435 |
|
t.join(); |
436 |
|
} |
487 |
|
}}); |
488 |
|
|
489 |
|
t.start(); |
490 |
< |
Thread.sleep(SHORT_DELAY_MS); |
490 |
> |
delay(SHORT_DELAY_MS); |
491 |
|
t.interrupt(); |
492 |
|
t.join(); |
493 |
|
} |
773 |
|
|
774 |
|
executor.execute(new CheckedRunnable() { |
775 |
|
public void realRun() throws InterruptedException { |
776 |
< |
Thread.sleep(SHORT_DELAY_MS); |
776 |
> |
delay(SHORT_DELAY_MS); |
777 |
|
q.put(new PDelay(1)); |
778 |
|
}}); |
779 |
|
|