ViewVC Help
View File | Revision Log | Show Annotations | Download File | Root Listing
root/jsr166/jsr166/src/test/tck/LinkedBlockingQueueTest.java
(Generate patch)

Comparing jsr166/src/test/tck/LinkedBlockingQueueTest.java (file contents):
Revision 1.19 by jsr166, Sat Nov 21 19:11:53 2009 UTC vs.
Revision 1.21 by jsr166, Sat Nov 21 22:00:46 2009 UTC

# Line 341 | Line 341 | public class LinkedBlockingQueueTest ext
341       */
342      public void testTimedOffer() throws InterruptedException {
343          final LinkedBlockingQueue q = new LinkedBlockingQueue(2);
344 <        Thread t = new ThreadShouldThrow(InterruptedException.class) {
344 >        Thread t = new Thread(new CheckedRunnable() {
345              public void realRun() throws InterruptedException {
346                  q.put(new Object());
347                  q.put(new Object());
348 <                threadAssertFalse(q.offer(new Object(), SHORT_DELAY_MS, MILLISECONDS));
349 <                q.offer(new Object(), LONG_DELAY_MS, MILLISECONDS);
350 <            }};
348 >                assertFalse(q.offer(new Object(), SHORT_DELAY_MS, MILLISECONDS));
349 >                try {
350 >                    q.offer(new Object(), LONG_DELAY_MS, MILLISECONDS);
351 >                    shouldThrow();
352 >                } catch (InterruptedException success) {}
353 >            }});
354  
355          t.start();
356          Thread.sleep(SMALL_DELAY_MS);
# Line 463 | Line 466 | public class LinkedBlockingQueueTest ext
466       */
467      public void testTimedPollWithOffer() throws InterruptedException {
468          final LinkedBlockingQueue q = new LinkedBlockingQueue(2);
469 <        Thread t = new ThreadShouldThrow(InterruptedException.class) {
469 >        Thread t = new Thread(new CheckedRunnable() {
470              public void realRun() throws InterruptedException {
471 <                threadAssertNull(q.poll(SHORT_DELAY_MS, MILLISECONDS));
472 <                q.poll(LONG_DELAY_MS, MILLISECONDS);
473 <                q.poll(LONG_DELAY_MS, MILLISECONDS);
474 <            }};
471 >                assertNull(q.poll(SHORT_DELAY_MS, MILLISECONDS));
472 >                assertSame(zero, q.poll(LONG_DELAY_MS, MILLISECONDS));
473 >                try {
474 >                    q.poll(LONG_DELAY_MS, MILLISECONDS);
475 >                    shouldThrow();
476 >                } catch (InterruptedException success) {}
477 >            }});
478  
479          t.start();
480          Thread.sleep(SMALL_DELAY_MS);

Diff Legend

– Removed lines
+ Added lines
< Changed lines
> Changed lines