# | Line 741 | Line 741 | public class Phaser { | |
---|---|---|
741 | final Phaser root = this.root; | |
742 | long s; | |
743 | while ((s = root.state) >= 0) { | |
744 | < | long next = (s & ~(long)(MAX_PARTIES)) | TERMINATION_BIT; |
744 | > | long next = (s & ~((long)UNARRIVED_MASK)) | TERMINATION_BIT; |
745 | if (UNSAFE.compareAndSwapLong(root, stateOffset, s, next)) { | |
746 | // signal all threads | |
747 | releaseWaiters(0); |
– | Removed lines |
+ | Added lines |
< | Changed lines |
> | Changed lines |