Heim  >  Fragen und Antworten  >  Hauptteil

Gibt es Probleme mit der Parallelität, wenn der Stream von Java8 zum Betreiben externer Sammlungen verwendet wird?

Beschreibung: Entfernen Sie die Nicht-DataTime in cp. Ist der folgende Code sinnvoll? Gibt es ein Parallelitätsproblem mit deviceDataMap?

Map<String,Map<String,String>> deviceDataMap = new HashMap<>();
String cp = "DataTime=20040506010101;SB1-RT=1.1;SB2-RT=2.1";

List<String> cpValusList = Arrays.asList(cp.split(";"));

    cpValusList.stream().filter(item -> !item.contains("DataTime=")).forEach(item ->{
        String deviceId = item.substring(0,item.indexOf("-"));
        if(!deviceDataMap.containsKey(deviceId)){
            Map<String,String> oneDeviceIdValusMap = new HashMap<>();
            List<String> deviceIdValueList = Arrays.asList(item.split(","));
            deviceIdValueList.forEach(value->{
                String[] temp = value.split("=");
                oneDeviceIdValusMap.put(temp[0], temp[1]);
            });
            
            deviceDataMap.put(deviceId, oneDeviceIdValusMap);
        }
        
    });
代言代言2645 Tage vor875

Antworte allen(1)Ich werde antworten

  • 天蓬老师

    天蓬老师2017-06-23 09:15:05

    并行流就是一个把内容分成多个数据块,并用不不同的线程分别处理每个数据块的流

    上面代码应该不存在并发问题,看样还是对java8 stream的原理没搞明白啊》》》》http://blog.csdn.net/sunjin94...

    Antwort
    0
  • StornierenAntwort