由于RaceCondition，使用流迭代LinkedList正在更改结果列表

Question

我们在java8中使用Streams迭代LinkedList，并创建另一个列表。但是由于竞争条件，结果列表的大小超出了限制。

List<DesInfo> InfoList = new LinkedList<>();
documentList.stream()
            .parallel()
            .forEach(document -> {
                Info descriptiveInfo = objectFactory.createDescriptiveInfo();
                List<Document> documents = new ArrayList<>();
                documents.add(document);
                descriptiveInfo.setHotelInfo(getHotelInfo(document.get(CODE), documents));
                InfoList.add(Info);
            });

如果我们每次都运行此代码，我们都会看到为相同的documentList输入生成不同大小的InfoList。我浏览了一些论坛，他们提到LinkedList不是线程安全的，而是任何线程安全的集合。但我的要求不允许我离开LinkedList。我需要在相同的LinkedList中使用并行流功能。

谢谢，拉格万

Answer 1

使用集合而不是更改集合的状态。

首先创建一个映射函数：

private DesInfo documentToDesInfo(Document document){
    DesInfo info = objectFactory.createDescriptiveInfo();
    List<Document> documents = new ArrayList<>();
    documents.add(document);
    info.setHotelInfo(getHotelInfo(document.get(CODE), documents));
    return info;
}

然后在您的管道中使用它:

List<DesInfo> infoList = documentList.parallelStream()
                                     .map(this::documentToDesInfo)
                                     .collect(toCollection(LinkedList::new));

Answer 2

不要使用for每一个，而是使用集合器和map（）操作：

List<HotelDescriptiveInfo> hotelDescriptiveInfoList = documentList.parallelStream()
    .map(document -> {
        HotelDescriptiveInfo descriptiveInfo = objectFactory.createHotelDescriptiveInfo();
        List<Document> documents = new ArrayList<>();
        documents.add(document);
        descriptiveInfo.setHotelInfo(getHotelInfo(document.get(HOTEL_CODE), documents));
        return descriptiveInfo;
    })
    .collect(Collectors.toCollection(LinkedList::new));

< code>Stream api将负责处理，不允许出现竞争情况。