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

Comparing jsr166/src/test/tck/LinkedTransferQueueTest.java (file contents):
Revision 1.22 by jsr166, Tue Dec 1 06:03:49 2009 UTC vs.
Revision 1.23 by jsr166, Tue Dec 1 06:28:43 2009 UTC

# Line 351 | Line 351 | public class LinkedTransferQueueTest ext
351              public void realRun() throws InterruptedException {
352                  for (int i = 0; i < SIZE; ++i) {
353                      long t0 = System.nanoTime();
354 <                    threadAssertEquals(i, (int) q.poll(LONG_DELAY_MS,
355 <                                                       MILLISECONDS));
354 >                    assertEquals(i, (int) q.poll(LONG_DELAY_MS, MILLISECONDS));
355                      long millisElapsed = (System.nanoTime() - t0)/(1024 * 1024);
356                      assertTrue(millisElapsed < SMALL_DELAY_MS);
357                  }
# Line 462 | Line 461 | public class LinkedTransferQueueTest ext
461          assertTrue(q.remove(one));
462          assertTrue(q.remove(two));
463          assertTrue(q.add(three));
464 <        assertTrue(q.take() == three);
464 >        assertSame(q.take(), three);
465      }
466  
467      /**
# Line 675 | Line 674 | public class LinkedTransferQueueTest ext
674  
675          executor.execute(new CheckedRunnable() {
676              public void realRun() {
677 <                threadAssertTrue(q.offer(three, MEDIUM_DELAY_MS,
679 <                                         MILLISECONDS));
677 >                assertTrue(q.offer(three, MEDIUM_DELAY_MS, MILLISECONDS));
678              }});
679  
680          executor.execute(new CheckedRunnable() {
681              public void realRun() throws InterruptedException {
682                  Thread.sleep(SMALL_DELAY_MS);
683 <                threadAssertEquals(one, q.take());
683 >                assertEquals(one, q.take());
684              }});
685  
686          joinPool(executor);
# Line 1018 | Line 1016 | public class LinkedTransferQueueTest ext
1016                  threadAssertTrue(q.tryTransfer(hotPotato));
1017              }});
1018  
1019 <        assertTrue(q.poll(MEDIUM_DELAY_MS, MILLISECONDS) == hotPotato);
1019 >        assertSame(hotPotato, q.poll(MEDIUM_DELAY_MS, MILLISECONDS));
1020          checkEmpty(q);
1021          t.join();
1022      }
# Line 1041 | Line 1039 | public class LinkedTransferQueueTest ext
1039                  threadAssertTrue(q.tryTransfer(hotPotato));
1040              }});
1041  
1042 <        assertTrue(q.take() == hotPotato);
1042 >        assertSame(q.take(), hotPotato);
1043          checkEmpty(q);
1044          t.join();
1045      }
# Line 1071 | Line 1069 | public class LinkedTransferQueueTest ext
1069  
1070          Thread t = newStartedThread(new CheckedRunnable() {
1071              public void realRun() throws InterruptedException {
1072 <                threadAssertFalse
1073 <                    (q.tryTransfer(new Object(),
1076 <                                   SHORT_DELAY_MS, MILLISECONDS));
1072 >                assertFalse(q.tryTransfer(new Object(),
1073 >                                          SHORT_DELAY_MS, MILLISECONDS));
1074              }});
1075  
1076          Thread.sleep(SMALL_DELAY_MS);
# Line 1091 | Line 1088 | public class LinkedTransferQueueTest ext
1088  
1089          Thread t = newStartedThread(new CheckedRunnable() {
1090              public void realRun() throws InterruptedException {
1091 <                threadAssertTrue(q.tryTransfer(five,
1092 <                                               MEDIUM_DELAY_MS, MILLISECONDS));
1096 <                threadAssertTrue(q.isEmpty());
1091 >                assertTrue(q.tryTransfer(five, MEDIUM_DELAY_MS, MILLISECONDS));
1092 >                assertTrue(q.isEmpty());
1093              }});
1094  
1095          Thread.sleep(SHORT_DELAY_MS);

Diff Legend

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