Theo dõi các tác vụ đã hoàn thành trong ExecutorService

Question

Tôi đang viết một ứng dụng bằng Java sử dụng ExecutorService để chạy nhiều luồng.

Tôi muốn gửi nhiều tác vụ (hàng nghìn lần một lần) cho Người thi hành dưới dạng Cuộc gọi và khi hoàn tất, hãy truy xuất kết quả của họ. Cách tôi tiếp cận điều này là mỗi khi tôi gọi hàm submit(), tôi nhận được một tương lai mà tôi lưu trữ trong một ArrayList. Sau đó, tôi chuyển Danh sách tới một chuỗi liên tục lặp lại nó, gọi hàm future.get() với thời gian chờ để xem tác vụ đã hoàn thành chưa. đây có phải là cách tiếp cận đúng hay là quá kém hiệu quả?

CHỈNH SỬA --- Thông tin thêm --- Một vấn đề khác là mỗi Cuộc gọi có thời gian xử lý khác nhau. Vì vậy, nếu tôi chỉ cần lấy phần tử đầu tiên ra khỏi Danh sách và gọi get() vào nó, nó sẽ chặn trong khi kết quả của những người khác có thể trở nên có sẵn và chương trình sẽ không biết. Đó là lý do tại sao tôi cần phải tiếp tục lặp lại với thời gian chờ.

cảm ơn trước

Answer 1

Lưu ý rằng cuộc gọi đến Future.get sẽ chặn cho đến khi câu trả lời khả dụng. Vì vậy, bạn không cần một luồng khác để lặp qua danh sách mảng.

Xem ở đây https://blogs.oracle.com/CoreJavaTechTips/entry/get_netbeans_6

Answer 2

này là cách tiếp cận đúng hay là quá kém hiệu quả?

Đây không phải là cách tiếp cận chính xác. Bạn đang không cần thiết lặp lại trên ArrayList kiểm tra để hoàn thành nhiệm vụ.

Điều này rất đơn giản: Chỉ cần sử dụng: CompletionService. Bạn có thể dễ dàng bọc trình thực hiện hiện tại của bạn vào nó. Từ JavaDocs:

Nhà sản xuất gửi nhiệm vụ để thực thi. Người tiêu dùng hoàn thành nhiệm vụ và xử lý kết quả của họ theo thứ tự mà họ hoàn thành.

Về bản chất, CompletionService cung cấp cách lấy lại kết quả đơn giản bằng cách gọi take(). Nó là một chức năng chặn và người gọi sẽ chặn cho đến khi kết quả có sẵn.

---