如何让 java.concurrency.CyclicBarrier 按预期工作

Question

我正在编写将生成两个线程的代码，然后等待它们使用 CyclicBarrier 类同步。问题是循环屏障没有按预期工作，并且主线程不会等待各个线程完成。我的代码如下所示：

 class mythread extends Thread{
   CyclicBarrier barrier;
   public mythread(CyclicBarrier barrier) { 
       this.barrier = barrier;
      }

   public void run(){
            barrier.await();
       } 
 }



class MainClass{
 public void spawnAndWait(){
    CyclicBarrier barrier = new CyclicBarrier(2);
    mythread thread1 = new mythread(barrier).start();
    mythread thread2 = new mythread(barrier).start();
    System.out.println("Should wait till both threads finish executing before printing this");
  }
}

知道我做错了什么吗？或者有没有更好的方法来编写这些屏障同步方法？请帮忙。

Answer 1

在执行主线程期间，您创建两个其他线程并告诉它们互相等待。但是你没有写任何东西让你的主线程等待它们并抱怨它不等待。顺便说

CyclicBarrier barrier = new CyclicBarrier(3);
mythread thread1 = new mythread(barrier).start();
mythread thread2 = new mythread(barrier).start();
barrier.await(); // now you wait for two new threads to reach the barrier.
System.out.println("Should wait till both threads finish executing before printing this");

一句。除非必要，否则不要扩展 Thread 类。实现 Runnable 并将实现传递给 Thread 对象。像这样：

class MyRunnable implements Runnable {
    public void run(){
        // code to be done in thread
    }
}

Thread thread1 = new Thread(MyRunnable);
thread1.start();

编辑
避免扩展线程的理由。
经验法则是尽可能减少耦合。继承是类之间非常牢固的联系。如果您想要更改 Thread 的某些默认行为（即覆盖某些方法）或想要访问 Thread 类的某些受保护字段，则必须从 Thread 继承。如果您不想要它，您可以选择更松散的耦合 - 实现 Runnable 并将其作为构造函数参数传递给 Thread 实例。

Answer 2

将 Runnable 实例传递给 CyclicBarrier 的构造函数，如下所示。

CyclicBarrier barrier = new CyclicBarrier(2, new Runnable() {

    @Override
    public void run() {
        System.out.println("Should wait till both threads finish executing before printing this");
    }
});

new mythread(barrier).start();
new mythread(barrier).start();

Answer 3

您正在寻找 Thread.join() 方法...

thread1.join();
thread2.join();
System.out.println("Finished");

编辑：因为注释...

如果您不想永远等待，您还可以指定最大毫秒数加纳秒等待线程死亡

Answer 4

在这种情况下，循环屏障不是正确的选择。您必须在此处使用 CountDownLatch。

我假设您正在从 main 方法调用 spawnAndWait 方法。

这不起作用的原因是 CyclicBarrier 有 2 个构造函数。要执行后操作，您必须使用 2 参数构造函数。最重要的是要记住，主线程不会通过 await 方法等待；但仍将继续执行。但是，CyclicBarrier 构造函数中指定的线程仅当所有生成的线程在屏障处停止时才会运行（通过 await 方法）