집행자 또는 withPool 구조체

Question

컬렉션이 있습니다. 컬렉션의 모든 항목에 대해 웹 서비스 호출을 한 다음 캐시에서 항목을 업데이트해야합니다. 나는 이것을 순차적으로하고 있지만 너무 느리다. 컬렉션의 항목과 해당 웹 서비스 호출은 서로 독립적입니다. 따라서 어떤 웹 서비스 호출도 다른 것과 간섭하지 않습니다.

그래서 저는 이것을 병렬로하고 싶습니다.

withGroup { 
} 

구조체를 사용하려고했으나 클로저 제어 내에서 완전히 작동하는 데이터에만 적합합니까? 다른 방법은 Java 실행 프로그램을 사용하는 것입니다.

Answer 1

약 promises?

뭔가 같은 :

def promises = items.collect{ item -> 
    task { 
     triggerWebService(item) 
    } 
} 
def result = waitAll(promises)