ViewVC Help
View File | Revision Log | Show Annotations | Download File | Root Listing
root/jsr166/jsr166/src/main/java/util/concurrent/Phaser.java
(Generate patch)

Comparing jsr166/src/main/java/util/concurrent/Phaser.java (file contents):
Revision 1.67 by jsr166, Sun Oct 9 22:33:10 2011 UTC vs.
Revision 1.68 by jsr166, Sun Oct 9 22:51:42 2011 UTC

# Line 373 | Line 373 | public class Phaser {
373                          int nextPhase = (phase + 1) & MAX_PHASE;
374                          n |= (long)nextPhase << PHASE_SHIFT;
375                          UNSAFE.compareAndSwapLong(this, stateOffset, s, n);
376 +                        releaseWaiters(phase);
377                      }
378                      else if (nextUnarrived == 0) { // propagate deregistration
379                          phase = parent.doArrive(ONE_DEREGISTER);
# Line 381 | Line 382 | public class Phaser {
382                      }
383                      else
384                          phase = parent.doArrive(ONE_ARRIVAL);
384                    releaseWaiters(phase);
385                  }
386                  return phase;
387              }

Diff Legend

Removed lines
+ Added lines
< Changed lines
> Changed lines