java.util.stream.Stream과 병렬로 두 개의 목록 처리

Question

각 요소에 대해 각 목록의 i에 대해 작업을 수행합니다. 요소는 임의의 순서로 처리 될 수 있습니다. 오래된 자바 예를 들면 : 그래서 요소를 병렬로 처리 할 수 ​​java.util.stream.Stream와이를 구현하는 가장 좋은 방법입니다

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(); 
} 

?

Answer 1

목록을 모두 스트리밍 할 수 있다고 생각하지 않도록 두 목록을 병렬로 작업해야합니다. 당신이 인덱스를 스트리밍하고 작업 할 수 있습니다 그러나 : Stream이 새로운

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

해서 당신이 자바가 제공하는 대한 다른 모든 도구를 잊어 버린 것을 의미하지 않는다. 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();