问题描述
当前代码:
List<MyObj> updateObj = ....<logic here>;
updateObj.stream().forEach(obj -> updateMyDB(obj));
这里每个 obj 都按顺序执行并花费更多时间。现在我希望将它并行化。这样做的最佳方法是什么?
选项 1:
updateObj.parallelStream().foreach(obj->updateMyObj(obj));
选项 2:
ExecutorService executor = new FixedThreaadPool(10);
updateObj.stream().foreach(obj -> CompletableFuture.runAsync(()-> updateMyObj(obj),executor));
这里的目的是并行化操作。有什么想法可以实现这一目标吗?
解决方法
暂无找到可以解决该程序问题的有效方法,小编努力寻找整理中!
如果你已经找到好的解决方法,欢迎将解决方案带上本链接一起发送给小编。
小编邮箱:dio#foxmail.com (将#修改为@)