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.20 by jsr166, Sat Nov 21 21:00:34 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);

Diff Legend

Removed lines
+ Added lines
< Changed lines
> Changed lines