我正在学习Phaser。在这样做的同时，我遇到了一个问题。以下是我的代码，
public class RunnableTask implements Runnable {
private Phaser phaser;
public RunnableTask(Phaser phaser) {
this.phaser = phaser;
this.phaser.register(); // Question
}
@Override
public void run() {
// this.phaser.register(); // Question
print("After register");
for (int i = 0; i < 2; i++) {
sleep();
print("Before await" + i + ":");
this.phaser.arriveAndAwaitAdvance();
print("After advance" + i + ":");
}
}
private void sleep() {
try {
TimeUnit.SECONDS.sleep(2);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
private void print(String msg) {
System.out.println(String.format("%s: %s, time=%s, registered=%s, arrived=%s, unarrived=%s, phase=%s.", msg,
Thread.currentThread().getName(), LocalTime.now(), this.phaser.getRegisteredParties(),
this.phaser.getArrivedParties(), this.phaser.getUnarrivedParties(), this.phaser.getPhase()));
}
}
上述样品测试
public class TestPhaser {
public static void main(String[] args) {
Phaser phaser = new Phaser();
RunnableTask task = new RunnableTask(phaser);
Thread t1 = new Thread(task, "t1");
Thread t2 = new Thread(task, "t2");
Thread t3 = new Thread(task, "t3");
t1.start();
t2.start();
t3.start();
}
}
执行上述程序后，输出为：
注册后：t3，时间= 22：01：26.636，注册= 1，到达= 0，未获得= 1，阶段= 0。
注册后：t2，时间= 22：01：26.636，注册= 1，到达= 0，未获得= 1，阶段= 0。
注册后：t1，时间= 22：01：26.636，注册= 1，到达= 0，未获得= 1，阶段= 0。
在等待0 :: t3之前，时间= 22：01：28.728，注册= 1，到达= 0，未获得= 1，阶段= 0。
在等待0 :: t2之前，时间= 22：01：28.728，注册= 1，到达= 0，未获得= 1，阶段= 0。
在等待0 :: t1之前，时间= 22：01：28.728，注册= 1，到达= 0，未获得= 1，阶段= 0。
在提前0 :: t1之后，时间= 22：01：28.728，注册= 1，到达= 0，未获得= 1，阶段= 3。
在提前0 :: t2之后，时间= 22：01：28.728，注册= 1，到达= 0，未获得= 1，阶段= 3。
在提前0 :: t3之后，时间= 22：01：28.729，注册= 1，到达= 0，未获得= 1，阶段= 3。
在等待1 :: t2之前，时间= 22：01：30.730，注册= 1，到达= 0，未获得= 1，阶段= 3。
在等待1 :: t3之前，时间= 22：01：30.730，注册= 1，到达= 0，未获得= 1，阶段= 3。
在提前1 :: t2之后，时间= 22：01：30.730，注册= 1，到达= 0，未获得= 1，阶段= 4。
在提前1 :: t3之后，时间= 22：01：30.732，注册= 1，到达= 0，未获得= 1，阶段= 5。
在等待1 :: t1之前，时间= 22：01：30.730，注册= 1，到达= 0，未获得= 1，阶段= 3。
在提前1 :: t1之后，时间= 22：01：30.732，注册= 1，到达= 0，未获得= 1，阶段= 6。
你可以看到这里有很多不符点之处。线程不按顺序前进。此外，缺少的阶段或/和序列中没有。
当我将构造函数中的代码行this.phaser.register（）从构造函数移动到run方法的开头时，输出为：
注册后：t1，时间= 22：10：58.230，注册= 3，到达= 0，未获得= 3，阶段= 0。
注册后：t3，时间= 22：10：58.230，注册= 3，到达= 0，未获得= 3，阶段= 0。
注册后：t2，时间= 22：10：58.230，注册= 3，到达= 0，未获得= 3，阶段= 0。
在等待0 :: t2之前，时间= 22：11：00.314，注册= 3，到达= 0，未获得= 3，阶段= 0。
在等待0 :: t1之前，时间= 22：11：00.314，注册= 3，到达= 0，未获得= 3，阶段= 0。
在等待0 :: t3之前，时间= 22：11：00.314，注册= 3，到达= 0，未获得= 3，阶段= 0。
在提前0 :: t2之后，时间= 22：11：00.315，注册= 3，到达= 0，未获得= 3，阶段= 1。
在提前0 :: t3之后，时间= 22：11：00.315，注册= 3，到达= 0，未获得= 3，阶段= 1。
在提前0 :: t1之后，时间= 22：11：00.315，注册= 3，到达= 0，未获得= 3，阶段= 1。
在等待1 :: t1之前，时间= 22：11：02.319，注册= 3，到达= 0，未获得= 3，阶段= 1。
在等待1 :: t2之前，时间= 22：11：02.319，注册= 3，到达= 0，未获得= 3，阶段= 1。
在等待1 :: t3之前，时间= 22：11：02.319，注册= 3，到达= 0，未获得= 3，阶段= 1。
在提前1 :: t3之后，时间= 22：11：02.320，注册= 3，到达= 0，未获得= 3，阶段= 2。
在提前1 :: t2之后，时间= 22：11：02.320，注册= 3，到达= 0，未获得= 3，阶段= 2。
在提前1 :: t1之后，时间= 22：11：02.321，注册= 3，到达= 0，未获得= 3，阶段= 2。
这看起来好于线程执行和阶段在一个序列中。
这是我的问题：
1）为什么派对在Runnable的构造函数中注册时会有很多差异？
2）在第二个结果中，到达和未到达的统计数据在每个阶段都为零（不正确）。那么，如何为他们获取正确的数字？
任何帮助表示赞赏。
在第一个示例“在构造函数中创建移相器”中，您只向Phaser注册一个线程。您必须创建三个任务，在移相器中注册三个线程。
像这样更改代码，它会起作用。 （别忘了从你的代码中删除初始的RunnableTask task = new RunnableTask（phaser）;
Thread t1 = new Thread(new RunnableTask(phaser), "t1");
Thread t2 = new Thread(new RunnableTask(phaser), "t2");
Thread t3 = new Thread(new RunnableTask(phaser), "t3");
在第二个例子中，你在所有线程中等待2秒，这是精确的，并且所有线程都到达并且几乎同时等待，改变你的睡眠方法，为这些线程引入一些不同的等待，看看有些到达和未获得的线程
private void sleep() {
try {
Random r = new Random();
TimeUnit.SECONDS.sleep(r.nextInt(5));
} catch(InterruptedException e) {
e.printStackTrace();
}
}
你的第二个例子有效，但它不正确。它的工作原理只是因为你在run方法的开头有睡眠所以所有的线程都会在你调用到达之前注册到phaser中并在phaser上使用advance方法。如果您在调用此行后删除睡眠
t1.start();
将运行T1 run方法，并且t1线程将在移相器中注册。然后可能会在线程t2和t3启动并在移相器中注册之前调用t1 run方法中的this.phaser.arriveAndAwaitAdvance（），因此移相器不会等待它们。
您应该在任务的构造函数中注册到phaser，或者在启动线程之前调用的方法中注册。