java中UPDATE语句的并发执行

问题描述

我有一个对象列表,我为其提交了更新数据库语句,如下所示。

当前代码

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 (将#修改为@)