多线程实现一个累加(可以是具体业务)操作
public static void main(String[] args) throws Exception { long start = System.currentTimeMillis();
Integer count = 100;
Integer sum = 0;
for (int a = 0; a < count; a++) {
sum += a;
Thread.sleep(100);
}
System.out.println(String.format("结果:%d
耗时:%d", sum, System.currentTimeMillis() - start));
}
执行结果:结果:4950 耗时:10054
可以看到耗时10秒;
优化方案
通过线程异步执行实现累加
public static void main(String[] args) throws Exception { long start = System.currentTimeMillis();
Integer count = 100;
CountDownLatch countDownLatch = new CountDownLatch(count);
AtomicInteger sum = new AtomicInteger(0);
for (int a = 0; a < count; a++) {
final Integer e = a;
new Thread(
()->{
sum .getAndAdd(e);
try {
Thread.sleep(100);
} catch (InterruptedException e1) {
e1.printStackTrace();
}
countDownLatch.countDown();
}
).start();
}
countDownLatch.await();
System.out.println(String.format("结果:%d
耗时:%d", sum.get(), System.currentTimeMillis() - start));
}
执行结果:结果:4950 耗时:159
总结:
多线程方案需要啊注意的点:
- 1、线程安全性?
在这个使用了AtomicInteger这个是线程安全,保证了数据正确性 - 2、这么多的线程同时执行,什么时候才能结束?
这里使用CountDownLatch,在完成最后一次计算后通知程序已经计算完成,节省等待时间
这里说一下, Thread.sleep(100); 目的是代表费时的业务逻辑,单纯数字累加的话,100个不用多线程,单线程更快一些。
还有CountDownLatch的使用需要注意一下。
本文转载: 感谢原作者, https://blog.csdn.net/weixin_37910453/article/details/86523454
以上是 多线程实现一个累加(可以是具体业务)操作 的全部内容, 来源链接: utcz.com/z/516596.html