26 |
|
} |
27 |
|
|
28 |
|
private static final int maxParties = 65535; |
29 |
< |
|
29 |
> |
|
30 |
|
/** Checks state of phaser. */ |
31 |
|
protected void assertState(Phaser phaser, |
32 |
|
int phase, int parties, int unarrived) { |
329 |
|
Phaser parent = new Phaser(); |
330 |
|
Phaser child = new Phaser(parent); |
331 |
|
assertState(child, 0, 0, 0); |
332 |
< |
assertState(parent, 0, 1, 1); |
332 |
> |
assertState(parent, 0, 0, 0); |
333 |
|
assertEquals(0, child.register()); |
334 |
|
assertState(child, 0, 1, 1); |
335 |
|
assertState(parent, 0, 1, 1); |
362 |
|
Phaser root = new Phaser(); |
363 |
|
Phaser parent = new Phaser(root); |
364 |
|
Phaser child = new Phaser(parent); |
365 |
< |
assertState(root, 0, 1, 1); |
366 |
< |
assertState(parent, 0, 1, 1); |
365 |
> |
assertState(root, 0, 0, 0); |
366 |
> |
assertState(parent, 0, 0, 0); |
367 |
|
assertState(child, 0, 0, 0); |
368 |
|
assertEquals(0, child.register()); |
369 |
|
assertState(root, 0, 1, 1); |