Java có hồ bơi chủ đề nhiều hàng có thể lập chỉ mục không?

Question

Có một lớp Java ví dụ rằng:

1. nhiệm vụ thực thi có thể được thêm vào thông qua một id, nơi mà tất cả các công việc với cùng id được đảm bảo để không bao giờ chạy đồng thời
2. Số chủ đề có thể được giới hạn trong một số tiền cố định

Một giải pháp ngây thơ của Bản đồ sẽ dễ dàng giải quyết (1), nhưng sẽ khó quản lý (2). Tương tự, tất cả các lớp gộp nhóm mà tôi biết sẽ kéo từ một hàng đợi duy nhất, có nghĩa là (1) không được đảm bảo.

Các giải pháp liên quan đến thư viện bên ngoài được hoan nghênh.

Answer 1

Nếu bạn không tìm thấy thứ gì đó thực hiện điều này, bạn không nên tự cuộn. Một điều bạn có thể làm là để quấn mỗi công việc trong một lớp học đơn giản mà đọc trên một hàng đợi duy nhất trên mỗi id, ví dụ .:

public static class SerialCaller<T> implements Callable<T> { 
    private final BlockingQueue<Caller<T>> delegates; 

    public SerialCaller(BLockingQueue<Caller<T>> delegates) { 
     this.delegates = delegates; 
    } 

    public T call() throws Exception { 
     return delegates.take().call(); 
    } 
} 

Nó phải là dễ dàng để duy trì một bản đồ của id để hàng đợi để nộp nhiệm vụ. Điều kiện thỏa mãn (1), và sau đó bạn có thể tìm các giải pháp đơn giản cho điều kiện (2), chẳng hạn như Executors. newFixedThreadPool

Answer 2

Tôi nghĩ rằng giải pháp đơn giản nhất là chỉ có một hàng đợi riêng biệt cho mỗi chỉ mục và một người thực hiện riêng biệt (với một chuỗi) cho mỗi hàng đợi.

Điều duy nhất bạn có thể đạt được với giải pháp phức tạp hơn là sử dụng ít chuỗi hơn, nhưng nếu số lượng chỉ mục nhỏ và bị ràng buộc thì có lẽ không đáng để nỗ lực.

Answer 3

Đối với mỗi id, bạn cần một SerialExecutor, được mô tả trong tài liệu của java.util.concurrent.Executor. Tất cả các nhà thực thi nối tiếp ủy nhiệm công việc cho một số ThreadPoolExecutor với corePoolSize đã cho.

Phiên bản Opimized của SerialExecutor có thể được tìm thấy tại my code samples.