ngã ba và tham gia sử dụng Akka

Question

tuyên bố vấn đề: Tôi có danh mục chứng khoán cần được xử lý theo cách song song. Trong Java, tôi đã sử dụng một threadpool để xử lý từng bảo mật và sử dụng một chốt để đếm ngược. Sau khi hoàn tất, tôi sẽ thực hiện một số hợp nhất, v.v.

Vì vậy, tôi thông báo Bộ phận xử lý bảo mật của tôi (là diễn viên) và chờ tất cả các tương lai hoàn thành. Cuối cùng tôi sử dụng một MergeHelper để thực hiện xử lý hậu kỳ. SecurityProcessor có bảo mật, có một số i/o và xử lý và trả lời An ninh

Thiết kế này có chính xác không và có cách nào tốt hơn để thực hiện vấn đề thường gặp này bằng cách sử dụng akka?

Answer 1

val futureResult = Future.sequence(
        portfolio.getSecurities.toList map { security => (actorOf[SecurityProcessor].start() ? security).mapTo[Security] } 
       ) map { securities => MergeHelper.merge(portfolio, securities) }