Gói một loạt các cuộc gọi không đồng bộ với một phương thức đồng bộ với giá trị trả về

Question

Mã hiện tại của tôi sử dụng hàng loạt các quy trình không đồng bộ đạt đến kết quả cao nhất. Tôi cần phải bọc mỗi trong số này theo cách mà mỗi được truy cập bởi một phương pháp đồng bộ với kết quả như là một giá trị trả về. Tôi muốn sử dụng dịch vụ thực thi để thực hiện điều này, để cho phép nhiều dịch vụ này xảy ra cùng một lúc. Tôi có cảm giác rằng Tương lai có thể thích hợp với việc thực hiện của tôi, nhưng tôi không thể tìm ra cách tốt để thực hiện điều này.

Những gì tôi có bây giờ:

public class DoAJob { 
    ResultObject result; 

    public void stepOne() { 
    // Passes self in for a callback 
    otherComponent.doStepOne(this); 
    } 

    // Called back by otherComponent once it has completed doStepOne 
    public void stepTwo(IntermediateData d) { 
    otherComponent.doStepTwo(this, d); 
    } 

    // Called back by otherComponent once it has completed doStepTwo 
    public void stepThree(ResultObject resultFromOtherComponent) { 
    result = resultFromOtherComponent; 
    //Done with process 
    } 
} 

này đã làm việc khá tốt trong nội bộ, nhưng bây giờ tôi cần phải lập bản đồ quy trình của tôi vào một phương pháp đồng bộ với một giá trị trả về như:

public ResultObject getResult(){ 
    // ??? What goes here ??? 
} 

Có ai có một ý tưởng hay về cách thực hiện điều này một cách thanh lịch?

Answer 1

Tôi đã làm điều tương tự với thư viện ổi; những liên kết này có thể chỉ cho bạn đi đúng hướng:

Is it possible to chain async calls using Guava?

https://code.google.com/p/guava-libraries/wiki/ListenableFutureExplained

Answer 2

tôi khuyên bạn nên sử dụng invokeAll(..). Nó sẽ gửi một tập hợp các nhiệm vụ cho người thi hành và chặn cho đến khi người cuối cùng hoàn thành (thành công/với ngoại lệ). Sau đó nó trả về một danh sách các đối tượng tương lai đã hoàn thành, vì vậy bạn có thể lặp lại chúng và kết hợp các kết quả vào một ResultObject đơn lẻ.

Trong bạn muốn chạy chỉ có một nhiệm vụ duy nhất một cách đồng bộ, bạn có thể sử dụng như sau:

executor.invokeAll(Collections.singleton(task)); 

--edit--

Bây giờ tôi nghĩ mình hiểu rõ hơn về nhu cầu của bạn. Tôi cho rằng bạn cần một cách để gửi các chuỗi nhiệm vụ độc lập. Vui lòng xem mã tôi đã đăng trong this answer.

Answer 3

Nếu bạn muốn bật một hoạt động không đồng bộ (thực hiện gọi lại khi hoàn tất), thành một đồng bộ/chặn, bạn có thể sử dụng hàng đợi chặn. Bạn có thể quấn nó lên trong một đối tượng tương lai nếu bạn muốn.

1. Xác định một hàng đợi chặn có sức chứa chỉ là một phần tử:

   BlockingQueue<Result> blockingQueue = new ArrayBlockingQueue<Result>(1);

2. Bắt đầu quá trình đồng bộ của bạn (sẽ chạy ở chế độ nền), và viết gọi lại như vậy mà khi nó được thực hiện, nó thêm kết quả của nó vào hàng đợi chặn.

3. Trong thread foreground/ứng dụng của bạn, có mất() khỏi hàng đợi, mà khối cho đến khi một yếu tố trở nên có sẵn:

   Result result = blockingQueue.take();

tôi đã viết một cái gì đó tương tự trước (nhu cầu đề foreground để chặn phản hồi không đồng bộ từ máy từ xa) bằng cách sử dụng một cái gì đó như Tương lai, bạn có thể tìm mã ví dụ here.

Answer 4

Nếu bạn muốn để có được bàn tay của bạn bẩn, bạn có thể làm điều này

ResultObject result; 

public void stepOne() 

    otherComponent.doStepOne(this); 

    synchronized(this) 
     while(result==null) this.wait(); 
    return result; 

public void stepThree(ResultObject resultFromOtherComponent) 

    result = resultFromOtherComponent; 

    synchronized(this) 
     this.notify(); 

Hoặc bạn có thể sử dụng công cụ mức đồng thời cao hơn, như BlockingQueue, Semaphore, CountdownLatch, Phaser, vv vv

Note rằng DoAJob không phải là chủ đề an toàn - rắc rối đảm bảo nếu hai chủ đề gọi stepOne cùng một lúc.