当我在 CyclicBarrier 回调中调用 join 时应用程序挂起

Question

我在启动线程的地方有以下方法测试：

public static void main(String[] args) throws InterruptedException {
        List<Thread> threads = new ArrayList<>();
        final CyclicBarrier cyclicBarrier = new CyclicBarrier(1);
        Thread thread = new Thread(new CallbackThread(cyclicBarrier, threads));
        threads.add(thread);
        thread.start();          
    }

回调线程如下所示：

class CallbackThread implements Runnable {
    CyclicBarrier cyclicBarrier;
    List<Thread> threads;

    CallbackThread(CyclicBarrier cyclicBarrier, List<Thread> threads) {
        this.cyclicBarrier = cyclicBarrier;
        this.threads = threads;
    }

    @Override
    public void run() {
        try {
            cyclicBarrier.await();
        } catch (InterruptedException e) {
            e.printStackTrace();  //To change body of catch statement use File | Settings | File Templates.
        } catch (BrokenBarrierException e) {
            e.printStackTrace();  //To change body of catch statement use File | Settings | File Templates.
        }
        System.out.println("Threads started");
        for (Thread thread1 : threads) {
            try {
                thread1.join();
            } catch (InterruptedException e) {
                e.printStackTrace();  //To change body of catch statement use File | Settings | File Templates.
            }
        }
        System.out.println("Threads finished");

    }
}

当我运行应用程序时，我看到以下输出：

Threads started

应用程序挂起。

我不明白为什么。

如果将连接逻辑替换为 main 方法 - 一切顺利。

public static void main(String[] args) throws InterruptedException {
        List<Thread> threads = new ArrayList<>();
        final CyclicBarrier cyclicBarrier = new CyclicBarrier(1);
        Thread thread = new Thread(new CallbackThread(cyclicBarrier, threads));
        threads.add(thread);
        thread.start();
        for (Thread thread1 : threads) {
            try {
                thread1.join();
            } catch (InterruptedException e) {
                e.printStackTrace();  //To change body of catch statement use File | Settings | File Templates.
            }
        }
        System.out.println("Threads finished");

    }

你能解释一下这个区别吗？
恕我直言，它应该可以正常工作。

Answer 1

第一个示例中的代码在其自己的线程上调用 join。您将它添加到列表中，线程遍历列表并加入列表中的每个线程。

Answer 2

您将在 self 上加入。这就是为什么程序永远不会结束。

当您从主线程调用 join() 时，主线程会尝试加入它创建的线程 CallableThread。所以是对的。

但是当您加入 CallableThread 时，您将传递 threads[]，其中包含对自身的引用。所以它正在加入自己，这不会结束。

当我在 CyclicBarrier 回调中调用 join 时应用程序挂起

Application hangs when I invoke join inside CyclicBarrier callback

java

multithreading

concurrency

cyclicbarrier