與java.util.stream.Stream並行處理兩個列表

Question

對於每個列表中的每個元素i執行操作。元素可以按任何順序處理。例如，在舊的Java：

List<A> aList; 
List<B> bList; // aList is larger than bList 

for (int i=0; i<bList.size(), i++) { 
    aList.get(i).doSomethingWith(bList.get(i)); 
} 

for (int j=i; j<aList.size(), j++) { 
    aList.get(j).doSomething(); 
} 

這與java.util.stream.Stream所以元素可以被並行處理來實現這一目標的最佳方式是什麼？

Answer 1

你需要並行處理兩個列表，所以我不認爲你可以自己流列表。然而，你可以流指標和關於工作：

IntStream.range(0, aList.size()) 
    .parallel() 
    .forEach(i -> { 
     if (i < bList.size()) aList.get(i).doSomethingWith(bList.get(i)); 
     else aList.get(i).doSomething(); 
    }); 

Answer 2

只是因爲Stream是新的，這並不意味着你應該忘記其他所有工具Java提供。即使使用這些優秀的舊工具，使用Java 8變得更流暢：

List<A> aList; 
List<B> bList; // aList is larger than bList 

ExecutorService exec = Executors.newCachedThreadPool(); 
int a=aList.size(), b=bList.size(); 
assert a>b; 
Future<?> f1=exec.submit(()->IntStream.range(0, b) 
    .parallel().forEach(i->aList.get(i).doSomethingWith(bList.get(i))) 
); 
Future<?> f2=exec.submit(()->aList.subList(b, a) 
    .stream().parallel().forEach(A::doSomething) 
); 
f1.get(); 
f2.get(); 
exec.shutdown();