如何“完全”同时启动两个线程

Question

线程应在同一瞬间开始。我知道，如果您这样做thread1.start()，则下次执行之前需要花费几毫秒的时间thread2.start()。

可能还是不可能？

Answer 1

要完全同时（至少尽可能好）启动线程，可以使用CyclicBarrier：// We want to start just 2 threads at the same time, but let's control that // timing from the main thread. That's why we have 3 "parties" instead of 2.final CyclicBarrier gate = new CyclicBarrier(3);Thread t1 = new Thread(){    public void run(){        gate.await();        //do stuff        }};Thread t2 = new Thread(){    public void run(){        gate.await();        //do stuff        }};t1.start();t2.start();// At this point, t1 and t2 are blocking on the gate. // Since we gave "3" as the argument, gate is not opened yet.// Now if we block on the gate from the main thread, it will open// and all threads will start to do stuff!gate.await();System.out.println("all threads started");不必一定是CyclicBarrier，您也可以使用CountDownLatch甚至是锁。这仍然不能确保它们在标准JVM上完全同时启动，但是您可以接近它们。当进行性能测试时，保持非常接近仍然很有用。例如，如果您尝试测量具有不同数量线程的数据结构的吞吐量，则希望使用这种结构来获得最准确的结果。在其他平台上，确切地说启动线程可能是非常有效的要求。

Answer 2

至少在单核计算机上是不可能的。但是，为什么要那样？即使您能够在完全相同的时间启动两个线程，它们的进度也会有所不同，因为调度不在您的控制范围内。编辑：（响应一些评论）同步多个线程的状态或进度是一个完全有效的要求，并且CyclicBarrier是一个很好的工具。我回答了是否可以同时完全启动多个线程的问题。CyclicBarrier将确保线程在完全处于所需状态时继续执行，但不能保证线程将在完全相同的时间启动或恢复，尽管可能非常接近。这个问题中没有提到同步需求。

Answer 3

您可以为此使用CountDownLatch。请在下面找到一个示例。尽管启动了t1和t2，但这些线程一直等待，直到主线程递减锁存器为止。构造函数中提到了所需的倒数次数。倒数锁存器也可以用于等待线程完成执行，以便主线程可以继续执行（相反的情况）。从Java 1.5开始包含该类。import java.util.concurrent.CountDownLatch;public class ThreadExample{    public static void main(String[] args)     {        CountDownLatch latch = new CountDownLatch(1);        MyThread t1 = new MyThread(latch);        MyThread t2 = new MyThread(latch);        new Thread(t1).start();        new Thread(t2).start();        //Do whatever you want        latch.countDown();          //This will inform all the threads to start        //Continue to do whatever    }}class MyThread implements Runnable{    CountDownLatch latch;    public MyThread(CountDownLatch latch)     {        this.latch = latch;    }    @Override    public void run()     {        try         {            latch.await();          //The thread keeps waiting till it is informed        } catch (InterruptedException e) {            e.printStackTrace();        }        //Do the actual thing    }}