완료된 미래를 추적하십시오

Question

저는 스칼라에서 Futures로 많은 수의 (~ 100.000) http 요청 태스크를 생성합니다. 이 작업은 시간이 걸리기 때문에 글로벌 카운터를 증가시킴으로써 얼마나 많은 선물이 성공적으로 완료되었거나 실패했는지 추적 할 수 있기를 바랍니다. 그러나 경쟁 조건을 피하기를 원합니다. 스칼라에 원자 카운터를 만드는 옵션이 있습니까? 아니면 더 좋은 방법이 있습니까?

코드는 다음과 같습니다

val futures = for(i <- 0 until nSteps) yield future { 
    ... 
    val content = blocking { ... http request ... } 
    process(content) 
} 
Await.result(Future.sequence(futures),2 hours) 

Answer 1

나는 표준 자바 AtomicInteger을 사용하는 것이 좋습니다 것입니다. incrementAndGet() 메서드를 사용하여 값을 증가시키고 get() 메서드를 통해 현재 값을 가져올 수 있습니다.

import java.util.concurrent.atomic.AtomicInteger 
... 
val completed = new AtomicInteger() 
val futures = for(i <- 0 until nSteps) yield future { 
    ... 
    val content = blocking { ... http request ... } 
    process(content) 
    completed.incrementAndGet() 
} 
Await.result(Future.sequence(futures),2 hours) 
... 
print("Completed: %d" format completed.get)