倒计时锁在Java中是如何工作的？[重复]

Question

我正在学习Java中的同步。我无法理解倒计时锁的确切机制。

CountDownLatch是否根据声明中给出的线程数“倒数锁存器”（等待线程数完成）？

这是我试图理解的代码：

public class LatchExample implements Runnable {
    private CountDownLatch latch;

    private int id;

    public LatchExample(int id, CountDownLatch latch){
        this.id=id;
        this.latch = latch;
    }

    public static void main(String[] args) {

        CountDownLatch latch = new CountDownLatch(5);

        ExecutorService executor = Executors.newFixedThreadPool(3);

        for (int i = 0; i < 7; i++) {
            executor.submit(new LatchExample(i,latch));
        }

        try {
            latch.await();
            System.out.println("all process completed");
        } catch (InterruptedException e) {
            e.printStackTrace();
        }


        System.out.println();
    }

    @Override
    public void run() {

        System.out.println("Starting: "+id);
        try {
            Thread.sleep(1000);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }

        latch.countDown();
    }
}

在上面的例子中：

ExecutorService（从线程池）生成7个线程。我的理解是闩锁应该等待6个线程（从0到5）的完成，定义如下：

CountDownLatch latch = new CountDownLatch(5);

但我得到的输出并不是每次都是恒定的。有时会等待6个线程完成，有时会等待7个线程完成，例如：

Starting: 1
Starting: 0
Starting: 2
Starting: 3
Starting: 5
Starting: 4
Starting: 6
all process completed

以下是交替时间的输出：

Starting: 0
Starting: 2
Starting: 1
Starting: 4
Starting: 5
Starting: 3
all process completed

Starting: 6

编辑：倒计时闩锁应该理想地倒计时，直到5个任务通过闩锁。这里显示为6或7。

如果我希望代码在“所有流程完成”之前始终只显示5个任务，那么代码的修复方法是什么？

Answer 1

尽管我的回答为时已晚，但希望这对像我这样不熟悉线程的人有所帮助。根据我的分析，倒计时闩锁按预期工作。请执行此更改并查看输出

 @Override
 public void run() {

    //System.out.println("Starting: "+id);
    try {
        Thread.sleep(1000);
    } catch (InterruptedException e) {
        e.printStackTrace();
    }

    latch.countDown();
    System.out.println("Finished the thread: "+id);
}

Answer 2

我认为理解CountDownLatch背后机制的最好方法是打个比方，所以我的2美分是这样的：想象一个迪斯科派对，你是DJ，在你数到舞池中有5个人之前，你不会放你最喜欢的歌曲“所有过程完成”。每次有人进来，你都倒数（从5开始），当你数到0时——你放上你最喜欢的歌。你不在乎他们是否都在舞池里，你只在乎你数到舞池里有5个人。

现在，对于您的示例，您将CountDownLatch=5并且您的for循环具有

你问：

CountDownLatch是否根据声明中给出的线程数“倒数锁存器”（等待线程数完成）？

不，它不等待线程完成，它根本不关心线程，它只关心你的计数。

在现实世界中，当您希望确保所有线程都执行了特定任务，并且现在可以继续使用main（或其他线程）时，将使用此机制。

Answer 3

你的闩锁将需要五次倒计时（）调用才能达到零，并让等待返回。但是，按照为执行器编写任务的方式，开始运行的任务将多于释放闩锁所需的任务。查看代码使用情况最有用的方法是一步一步地运行，如下所示：

1. 任务0-2开始在三个线程池线程上运行

现在，我不太清楚您期望您的代码会做什么，但我希望上述推理方式将帮助您将其带到其行为与您的期望一致的状态。