6

parallelstream() cung cấp song song liền mạch các hoạt động trên luồng trên các lõi của một máy.Các luồng trong Java 8: giải pháp đơn giản để sử dụng parallelstream() trên một cụm?

Làm cách nào để mở rộng logic này để parallelstream() phân phối các hoạt động này cho tất cả các máy của cụm?

Lý tưởng nhất:
- Tôi tạo một cụm máy, sử dụng khung công tác ??
- khởi chạy myCollection.parallelstream().filter(something).collect() phân phối công việc cho tất cả các lõi của tất cả các máy của cụm và trả về kết quả cho máy thí điểm cụm.

+0

Bạn cần cung cấp 'ForkJoinPool' của riêng mình nếu tôi nhớ chính xác – fge

+0

Tôi hầu như không bắt đầu thích ứng với Java 8 và mọi người đã nói về những thứ như thế này. Tôi đang tụt lại phía sau;) – CKing

+0

:-) tốt, trong cuốn sách tuyệt vời "Java 8 trong hành động", các tác giả tiếp tục nói rằng các nguyên tắc song song trên các lõi giữ cũng như song song trên các máy: vì vậy tôi chỉ hy vọng điều này mang lại! – seinecle

Trả lời

0

Spark dường như làm những gì bạn muốn, tức là phân phối công việc trên các nút. Dsl trông tương tự như java 8 stream. Bạn cũng có thể xem các luồng akka. Với dòng akka không cho phép bạn làm những gì bạn muốn ra khỏi hộp nhưng nó cung cấp cho bạn một hộp công cụ để giúp bạn với một dsl tốt đẹp.

Các vấn đề liên quan