java利用CountDownLatch实现并行计算
这篇文章主要介绍了java利用CountDownLatch实现并行计算，具有一定的参考价值，感兴趣的小伙伴们可以参考一下本文实例为大家分享了利用countdownlatch实现并行计算的具体代码，供大家参考，具体内容如下
import java.util.concurrent.countdownlatch;
/**
* @author pipi
* @date 2018/10/15 13:56
**/
public class parallelcomputing {
private int[] nums;
private string[] info;
private countdownlatch countdownlatch;
public parallelcomputing(string[] info) {
this.info = info;
int size = info.length;
nums = new int;
this.countdownlatch = new countdownlatch(size);
}
public void calc(string line, int index) throws interruptedexception {
string[] numbers = line.split(",");
int total = 0;
for (string num : numbers) {
total += integer.parseint(num);
}
thread.sleep(5000);
nums = total;
countdownlatch.countdown();
system.out.println(thread.currentthread().getname() + "执行计算任务..." + line + ",结果为：" + total);
}
public void sum() {
system.out.println("汇总线程开始执行...");
int total = 0;
for (int i : nums) {
total += i;
}
system.out.println("汇总线程结束执行...结果为：" + total);
}
public void calcsum() throws interruptedexception {
int size = info.length;
for (int i = 0; i < size; i++) {
final int j = i;
new thread(() -> {
try {
calc(info, j);
} catch (interruptedexception e) {
e.printstacktrace();
}
}).start();
}
countdownlatch.await();
sum();
}
public static void main(string[] args) throws interruptedexception {
long start = system.currenttimemillis();
string[] info = {
"2,22",
"3,33",
"232,32,76,84",
"99,45,1"
};
parallelcomputing parallelcomputing = new parallelcomputing(info);
parallelcomputing.calcsum();
long end = system.currenttimemillis();
system.out.println(end - start);
}
}
以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持CodeAE代码之家。
原文链接：https://www.cnblogs.com/ppcoder/p/9790922.html
http://www.zzvips.com/article/168590.html
页:
[1]