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