그루비 GPars는, 그루비와

Question

사용 GPars를 시작 각 스레드에 대한 인덱스를 필요, 나는 3 개 병렬로 몇 가지 작업을 수행하는 스레드 ...

GParsPool.withPool(3){ 
    result = myList.collectParallel{ 
     processItem(it) 
    } 
} 

이 잘 작동하지만 내가 폐쇄에 인덱스를 필요를 시작하는 실행 된 스레드 번호를 나타냅니다. 루프가 없기 때문에 이러한 인덱스에 액세스하는 방법을 모릅니다. 모든 것이 병행되고 있습니다.

나는 eachWithIndexParallel를 사용하여 시도,이,하지만 멋져요 (ArrayList를, 정수) 그루비에서

GParsPool.withPool(3) { 
    result = myList.eachWithIndexParallel{ i -> 
     processItem(it, i) 
    } 
} 

Answer 1

eachWithIndex() 폐쇄에 두 개의 인수를 전달하기위한 이러한 방법의 불만을 더 결과를 반환 : GParsPool합니다. withPool () myList.eachWithIndexParallel {e, i -> processItem (e, i) } } 설명하는 이유는 무엇입니까?

그러나 각 스레드로부터 안전한 결과를 얻으려면 특별한주의를 기울여야합니다.

요소를 처리하는 스레드의 식별을 얻는 한 가지 방법은 클로저 내부의 Thread.currentThread() 메서드를 쿼리하는 것입니다.