Description : supprimez le non-DataTime dans cp. Le code suivant est-il raisonnable ? Y a-t-il un problème de concurrence avec deviceDataMap ?
Map<String,Map<String,String>> deviceDataMap = new HashMap<>();
String cp = "DataTime=20040506010101;SB1-RT=1.1;SB2-RT=2.1";
Liste<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);
}
});
Le flux parallèle est un flux qui divise le contenu en plusieurs blocs de données et utilise différents threads pour traiter chaque bloc de données séparément
Il ne devrait y avoir aucun problème de concurrence dans le code ci-dessus. Il semble que je ne comprenne toujours pas le principe du flux java8》》》》http://blog.csdn.net/sunjin94...