如何计算我的多线程程序的运行时间答案

【问题标题】：How to calculate the running time of my multithreaded program如何计算我的多线程程序的运行时间
【发布时间】：2014-05-15 08:48:38
【问题描述】：

我正在尝试计算我的程序创建的所有线程的总数，但我的代码仅计算调用时间。

我确定是因为在输出中我看到在所有线程完成之前打印出差异

下面是我的主程序 RequestProcessor 这里是我的线程类

int i = 0;
List<Customer>customers = customer.getCustomers();
long startTimestamp = System.currentTimeMillis();
for (Customer c: customers){
    new RequestProcessor(c, i).start();
    i++;
}
long endTimestamp = System.currentTimeMillis();
System.out.println("difference  = "+(endTimestamp - startTimestamp));

下面是请求处理器类

public RequestProcessor( Customer customer , int threadSeq ) {
    super();
    this.customer = customer;
    this.threadSeq = threadSeq;
}

@Override
public void run() {
    // TODO Auto-generated method stub
    processRequest();
    super.run();
}

public void processRequest(){
    //performing execution on customer here
    System.out.println("processing "+ customer.getName()+" thread seq "+threadSeq);
}

下面是我得到的输出

processing customer9 thread seq 9
processing customer7 thread seq 7
difference  = 4
processing customer3 thread seq 3
processing customer2 thread seq 2

我尝试使用 join 但对我不起作用

【问题讨论】：

标签： java multithreading oop

【解决方案1】：

您可以使用 CountDownLatch 。它是一个重要的并发工具类。如果您想了解更多有关 java 多线程程序的信息。请参阅 Java 并发实践 [Brian Goetz]

一书

 int i = 0;
  List<Customer>customers = customer.getCustomers();
  CountDownLatch cdl =new CountDownLatch(customers.size());      // new code 
  long startTimestamp = System.currentTimeMillis();

   for (Customer c: customers){
      new RequestProcessor(cdl,c, i).start();
      i++;
    }

   cdl.await();                                                      // new code . 
  // the thread will hang up unitl all RequestProcessor run cdl.countDown() ;
    long endTimestamp = System.currentTimeMillis();
    System.out.println("difference  = "+(endTimestamp - startTimestamp));

RequestProcessor.class

public RequestProcessor(CountDownLatch cdl, Customer customer , int threadSeq ) {
        super();
        this.customer = customer;
        this.threadSeq = threadSeq;
        this.cdl=cdl;                                            // new code 
        }
    @Override
    public void run() {
        // TODO Auto-generated method stub
       processRequest();
       super.run();
       cdl.countDown();                                          // new code 
    }

【讨论】：

【解决方案2】：

您可以使用CountDownLatch 等待一定数量的线程调用countDown()，此时您可以打印运行时间。您需要更改您的 Customer 类以获取 CountDownLatch 对象，以便可以正确调用 countDown() 方法，但是一旦您这样做了，这应该可以工作。

类似：

CountDownLatch latch = new CountDownLatch(customers.size());
long startTimestamp = System.currentTimeMillis();
for (Customer c: customers){
    new RequestProcessor(c, i++, latch).start();
}
latch.await();
// have each thread call countDown() after it's done, etc.

你可能需要做一些更复杂的事情，比如有两个锁存器，这样你就可以通过让一个锁存器阻塞每个创建的线程来获得更好的时间，直到你在主线程中调用countDown()，但这是一般的想法.

【讨论】：