带地图的ParallelStream

Question

我想从复杂映射中读取值，并并行执行一个函数。为此，我使用了Java 8中的ForkJoinPool。

我在这里面临的问题是，对于少数值，函数执行两次。起初我认为，Hashmap不是线程安全的，所以我尝试使用HashTable，但它是相同的。。。

final Map<CakeOrder, List<CakeOrderDetails>> cakeOrderMap = cakeUpdatesQueueItemDao.getCakeOrdersByStatus(EItemStatus.OPENED, country.getDbTableSuffix(), true);
final Map<CakeOrder, List<CakeOrderDetails>> cakeOrderTableMap = new Hashtable<>();

cakeOrderMap.forEach((k, v) -> cakeOrderTableMap.put(k, v));

final ForkJoinPool pool = new ForkJoinPool(20);
pool.submit(() -> cakeOrderTableMap.entrySet()
   .stream()
   .parallel()
   .forEach(entry -> cakeService.updateCakeOrderStatusAndPrice(entry.getKey(), entry.getValue()))).invoke();

Answer 1

对于并行流，输入集合的线程安全性是不必要的，只要它没有更新。另一方面，哈希表。entrySet（）对于并行流来说是一个非常糟糕的源代码，因为哈希表没有自定义的拆分器实现。使用HashMap更好。然而，提供的代码一切都应该正常工作，无论是使用哈希映射还是哈希表（尽管使用哈希表效率要低得多）。我怀疑问题在cakeService中没有显示。updateCakeOrderStatusAndPrice，这可能不是线程安全的。