扫码关注官方订阅号
认证0级讲师
ExecutorService exec = Executors.newFixedThreadPool(8); for(final Object obj : list){ exec.execute(new Runnable() { @Override public void run() { process(obj) } }); }
我觉得使用这种方式更好。
java8 parallel stream
成员变量 index是多线程共享变量,你需要加volatile保证多线程中这个变量的可见性,声明代码改为如下:
private volatile int index = 0;
具体为什么请学习java并发编程相关基础知识
你这个run()里面最好采用线程同步
微信扫码关注PHP中文网服务号
QQ扫码加入技术交流群
Copyright 2014-2025 https://www.php.cn/ All Rights Reserved | php.cn | 湘ICP备2023035733号
PHP学习
技术支持
返回顶部
我觉得使用这种方式更好。
java8 parallel stream
成员变量 index是多线程共享变量,你需要加volatile保证多线程中这个变量的可见性,声明代码改为如下:
具体为什么请学习java并发编程相关基础知识
你这个run()里面最好采用线程同步