在不同类中使用执行器和同步CountDownLatch

Question

大家好，我正在学习一个教程，我对一些我尝试应用从教程中获得的知识的事情很好奇。

package Tutorial2;

import java.util.concurrent.CountDownLatch;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;

public class Runner {

    public void runIt() {

        CountDownLatch latch = new CountDownLatch (6);
        ExecutorService executor = Executors.newFixedThreadPool(2);

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

        ExecutorService executor2 = Executors.newFixedThreadPool(2);

        for (int i = 1000; i < 1010; i++) {
            executor2.submit(new Process(i, latch));
        }

        try {
            latch.await();
        } catch (InterruptedException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }

        System.out.println("Program Ended");
   }
}

package Tutorial2;

import java.util.concurrent.CountDownLatch;

public class Process implements Runnable {

    private int id;
    CountDownLatch latch = new CountDownLatch(6);

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

    @Override
    public void run() {
        System.out.println("Task Starting ID : " + id);

        try {
            Thread.sleep(3000);
        } catch (InterruptedException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }

        System.out.println("Task Finished ID : " + id);
        latch.countDown();
    }
}

我很好奇的是Runner类中的CountDownLatch和Process类中的CountDownLatch应该是不同的，但在Process类的CountDownLatch中达到零似乎也会触发。Await我在Runner类中放置了它。当我只将CountDownLatch作为参数传递给Process类，而Process类的CountDownLatch的值没有返回给Runner类时，这是如何工作的？

另外，在下面，我设置了两个执行器，这样每个执行器都将对CountDownLatch进行倒计时，但是在返回之前，我得到的处理线程数似乎比我输入的线程数（6）还要多。我做错了什么？当CountDownLatch达到0时，即线程已经从两个执行器中总共运行了6次，我如何使它能够打印“Program Ended”。

Answer 1

通过this.latch=latch；，您可以用传入构造函数参数的引用覆盖对象的引用（即在runit方法中创建的引用）。process类中的赋值CountDownLatch latch=new CountDownLatch(6)；毫无用处，它什么也不做。只是让你困惑。

第二个问题不清楚...是的，只要它倒数到零，它就会释放await...不确定它与您拥有多少线程/执行器有什么关系。