在线程区域中只执行一次代码

Question

在我正在工作的 Java 代码的某个部分，我需要在 run() 方法中放置一个计时器。每个线程将执行run() 内的所有代码。但我需要在块 (1) 之后和代码块 (2) 之前开始测量，因此需要在那里触发计时器。

for (int i = 0; i < total_threads-1; i++){
   final int id = i+1;          
   th[i] = new Thread(new Runnable() {              
       public final void run(){
             /* ... block of code (1) executed by multiple threads ... */

             /* How can i start this counter only once? */
             final long begin = System.currentTimeMillis();

             /* ... another block of code (2) executed by multiple threads i need to measure!!! ... */
       }
    });
    th[i].start();
}

for(int i = 0 ; i < total_threads-1 ; i++) {
    try {
           th[i].join();
        }
    catch (InterruptedException e) {}
}

final long end = System.currentTimeMillis();

System.out.println((end-begin) / 1000.0);

但是所有线程都有自己的begin 变量并启动计数器，这是一个问题，因为System.currentTimeMillis() 应该被触发一次，而不是由许多线程触发。 我可能可以将run() 的代码分隔在两个不同的并行区域中，但这意味着两次创建线程是不可接受的（就性能而言）。 使用 Java 线程的 Java 是否有类似的 OpenMP 指令 #pragma omp master 技术？ 我怎样才能在这里正确测量时间？

Answer 1

最简单的方法就是在主线程（即创建所有子线程的线程）中而不是在子线程中记录时间。

但如果你真的想在孩子中启动计时器（也许有一些昂贵的设置？），你可以使用 Guava StopWatch 对象。

代码如下所示：

StopWatch timer = StopWatch.createUnstarted();
for (int i = 0; i < total_threads-1; i++){
    final int id = i+1;
    th[i] = new Thread(() -> {
        /* ... block of code (1) executed by multiple threads ... */

        try {
            synchronized (timer) {
                timer.start();
            }
        } catch (IllegalStateException e) {
            // ignore; the watch is already started
        }

        /* ... another block of code (2) executed by multiple threads i need to measure!!! ... */
    });
    th[i].start();
}

for(int i = 0 ; i < total_threads-1 ; i++) {
    try {
        th[i].join();
    } catch (InterruptedException e) {}
}

timer.stop();

System.out.println(timer.elapsed(TimeUnit.SECONDS));

Answer 2

您可以检查线程 ID 以执行一次 prefer 行：

if (id == YOUR_THREAD_ID) 
{
     begin = System.currentTimeMillis();
}