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

Comparing jsr166/src/test/tck/PhaserTest.java (file contents):
Revision 1.8 by jsr166, Sat Nov 21 20:58:45 2009 UTC vs.
Revision 1.13 by jsr166, Wed Dec 2 19:02:37 2009 UTC

# Line 194 | Line 194 | public class PhaserTest extends JSR166Te
194          for (int i = 0; i < 10; i++)
195              phaser.register();
196              threads.add(newStartedThread(new CheckedRunnable() {
197 <                void realRun() throws InterruptedException {
197 >                public void realRun() throws InterruptedException {
198                      Thread.sleep(SMALL_DELAY_MS);
199                      phaser.arriveAndDeregister();
200                  }}));
# Line 295 | Line 295 | public class PhaserTest extends JSR166Te
295      public void testArriveAndDeregister6() throws InterruptedException {
296          final Phaser phaser = new Phaser(2);
297          Thread t = newStartedThread(new CheckedRunnable() {
298 <            void realRun() {
298 >            public void realRun() {
299                  sleepTillInterrupted(SHORT_DELAY_MS);
300                  phaser.arrive();
301              }});
# Line 330 | Line 330 | public class PhaserTest extends JSR166Te
330          phaser.register();
331  
332          Thread t = newStartedThread(new CheckedRunnable() {
333 <            void realRun() throws InterruptedException {
333 >            public void realRun() throws InterruptedException {
334                  phaser.register();
335                  sleepTillInterrupted(LONG_DELAY_MS);
336                  phaser.awaitAdvance(phaser.arrive());
# Line 353 | Line 353 | public class PhaserTest extends JSR166Te
353          List<Thread> threads = new ArrayList<Thread>();
354          for (int i = 0; i < 4; i++) {
355              threads.add(newStartedThread(new CheckedRunnable() {
356 <                void realRun() {
356 >                public void realRun() {
357                      int phase = phaser.arrive();
358                      phaseCount.incrementAndGet();
359                      sleepTillInterrupted(SMALL_DELAY_MS);
360                      phaser.awaitAdvance(phase);
361 <                    threadAssertTrue(phaseCount.get() == 4);
361 >                    assertEquals(phaseCount.get(), 4);
362                  }}));
363          }
364          for (Thread thread : threads)
# Line 376 | Line 376 | public class PhaserTest extends JSR166Te
376          List<Thread> threads = new ArrayList<Thread>();
377          for (int i = 0; i < 8; i++) {
378              threads.add(newStartedThread(new CheckedRunnable() {
379 <                void realRun() {
379 >                public void realRun() {
380                      sleepTillInterrupted(SHORT_DELAY_MS);
381                      phaser.arrive();
382                  }}));
383              phase = phaser.awaitAdvance(phaser.arrive());
384 <            threadAssertEquals(phase, phaser.getPhase());
384 >            assertEquals(phase, phaser.getPhase());
385          }
386          for (Thread thread : threads)
387              thread.join();
# Line 399 | Line 399 | public class PhaserTest extends JSR166Te
399           * waits for the second thread's party to arrive
400           */
401          Thread t1 = newStartedThread(new CheckedRunnable() {
402 <            void realRun() {
402 >            public void realRun() {
403                  sleepTillInterrupted(SMALL_DELAY_MS);
404                  int phase = phaser.awaitAdvance(phaser.arrive());
405                  /*
406                   * This point is reached when force termination is called in which phase = -1
407                   */
408 <                threadAssertTrue(phase < 0);
409 <                threadAssertTrue(phaser.isTerminated());
408 >                assertTrue(phase < 0);
409 >                assertTrue(phaser.isTerminated());
410              }});
411          /*
412           * This thread will cause the first thread run to wait, in doing so
# Line 414 | Line 414 | public class PhaserTest extends JSR166Te
414           * should exit peacefully as this one
415           */
416          Thread t2 = newStartedThread(new CheckedRunnable() {
417 <            void realRun() {
417 >            public void realRun() {
418                  sleepTillInterrupted(MEDIUM_DELAY_MS);
419                  int p1 = phaser.arrive();
420                  int phase = phaser.awaitAdvance(p1);
421 <                threadAssertTrue(phase < 0);
422 <                threadAssertTrue(phaser.isTerminated());
421 >                assertTrue(phase < 0);
422 >                assertTrue(phaser.isTerminated());
423              }});
424  
425          phaser.arrive();
# Line 446 | Line 446 | public class PhaserTest extends JSR166Te
446      public void testArriveAndAwaitAdvance2() throws InterruptedException {
447          final Phaser phaser = new Phaser(2);
448          Thread th = newStartedThread(new CheckedRunnable() {
449 <            void realRun() {
449 >            public void realRun() {
450                  phaser.arriveAndAwaitAdvance();
451              }});
452  
# Line 465 | Line 465 | public class PhaserTest extends JSR166Te
465       */
466      public void testArriveAndAwaitAdvance3() throws InterruptedException {
467          final Phaser phaser = new Phaser(1);
468 –        final AtomicInteger arrivingCount = new AtomicInteger(0);
468          final List<Thread> threads = new ArrayList<Thread>();
469 <        for (int i = 0; i < 6; i++) {
469 >        for (int i = 0; i < 3; i++) {
470              threads.add(newStartedThread(new CheckedRunnable() {
471 <                void realRun() throws InterruptedException {
472 <                    phaser.register();
473 <                    sleepTillInterrupted(SHORT_DELAY_MS);
474 <                    arrivingCount.getAndIncrement();
476 <                    phaser.arrive();
477 <                }}));
471 >                    public void realRun() throws InterruptedException {
472 >                        phaser.register();
473 >                        phaser.arriveAndAwaitAdvance();
474 >                    }}));
475          }
476 <        int phaseNumber = phaser.arriveAndAwaitAdvance();
477 <        arrivingCount.incrementAndGet();
478 <        //the + 1 adds to expectedArrive to account for the main threads arrival
482 <        int expectedArrived = phaseNumber > 0 ? phaseNumber * six + 1 : phaser.getArrivedParties() + 1;
483 <        threadAssertEquals(expectedArrived, arrivingCount.get());
476 >        Thread.sleep(MEDIUM_DELAY_MS);
477 >        assertEquals(phaser.getArrivedParties(), 3);
478 >        phaser.arriveAndAwaitAdvance();
479          for (Thread thread : threads)
480              thread.join();
481      }

Diff Legend

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