使用list.parallelStream().forEach()查询数据或插入数据遇到的问题看这里

在写一个功能时候为了提高查询速度我采用了list.parallelStream().forEach()方法来提高效率。
然后遇到两个问题：第一查询顺序被打乱。第二查询时候条件一直都是最最后一个取出的值（虽然打印的数据发生变化，但是看sql其实值没有变）。
–这主要是因为forEach中有个原子性问题。如果在直接只用字符串赋值就会产生提示，很不凑巧因为用的对象所以没有提示。
代码如下：

public List test(Spec spec){
List<String> strs= new ArrayList<>();
strs.add("12323");
strs.add("12324");
strs.add("12325");
strs.add("12326");
List list = new ArrayList();
strs.parallelStream().forEach(str-> {
StatisticalEmission statisticalEmission = new StatisticalEmission();
log.info(str);
spec.setId(str);
List resultList = statisticalEmissionMapper.select(spec);
statisticalEmission.setResultList(resultList );
list.add(statisticalEmission);
}
return list;
}

在执行时候就发现了一个问题:打印的日志str的值在变化，但是sql语句中条件没有发生改变。
也就是说 “12323”，“12324”，“12325”，"12326"值会在log日志中输出。而mapper中执行的sql语句条件一直都是最后一个取出的值。
解决办法：

import org.apache.commons.beanutils.BeanUtils;
public List test(Spec spec){
List<String> strs= new ArrayList<>();
strs.add("12323");
strs.add("12324");
strs.add("12325");
strs.add("12326");
List list = new ArrayList();
strs.parallelStream().forEach(str-> {
StatisticalEmission statisticalEmission = new StatisticalEmission();
log.info(str);
Spec newSpec = new Spec()
BeanUtils.copyProperties(newSpec , spec)
newSpec.setId(str);
List resultList = statisticalEmissionMapper.select(newSpec );
statisticalEmission.setResultList(resultList );
list.add(statisticalEmission);
}
return list;
}

这样其实还是有问题因为ArrayList是线程不安全的，进行并行操作会出现过快都出现空指针异常和数组下标越界问题。可以加上

	List newlist = Collections.synchronizedList(list);

顺序问题可以用对比然后排序，切记不要改成:

list.parallelStream().forEachOrdered()

这样线程数并没有发生变化。速度也没有多少提高。

最后

以上就是单身机器猫为你收集整理的使用list.parallelStream().forEach()查询数据或插入数据遇到的问题看这里的全部内容，希望文章能够帮你解决使用list.parallelStream().forEach()查询数据或插入数据遇到的问题看这里所遇到的程序开发问题。

如果觉得靠谱客网站的内容还不错，欢迎将靠谱客网站推荐给程序员好友。