博客

在写一个功能时候为了提高查询速度我采用了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()

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