Java thông báo() được gọi trước khi chờ()

Question

Không phải là có thể thông báo() trong một luồng khác được gọi trước khi chờ() trong một chuỗi? Nó đang xảy ra với tôi.

Máy khách yêu cầu giá trị từ mục tiêu và chờ trên biến kết quả RV. Trong trường hợp mục tiêu là chính máy khách, tôi cập nhật RV với kết quả chính xác và gọi thông báo() trên RV trong một chuỗi khác.

class EMU { 

    ResultVar RV; 
    Address my_address; 

    ResultVar findValue(String key) { 
    String tgt = findTarget(key); 
    sendRequest(tgt, key); 
    synchronized(RV) { 
     RV.wait(); 
    } 

    return RV; 
    } 

    Runnable Server = new Runnable() { 
    public void run() { 
     //code to receive connections. Assume object of type Request is read from the stream. 
     Request r = (Request) ois.readObject(); 
     if(r.requesterAddr.compareTo(my_address) == 0) { 
     String val = findVal(key); 
     RV.putVal(val); 
     synchronized(RV){ 
      RV.notify(); 
     } 
     } 
    } 
    }; 
} 

Vấn đề là trước khi người yêu cầu hoàn thành tất cả "mạng" (gửi chính xác trong ví dụ trên), kết quả được cập nhật trong biến kết quả. Khi chuỗi yêu cầu bây giờ gọi wait(), chương trình không tiếp tục, vì thông báo đã được gọi.

Làm cách nào để ngăn chặn?

Answer 1

Bạn kiểm tra một số cờ trước khi chờ đợi (trong một vòng lặp), vui lòng xem hướng dẫn: http://docs.oracle.com/javase/tutorial/essential/concurrency/guardmeth.html

Answer 2

Không có gì ngăn bạn gọi notify trên một đối tượng mà không phải là wait ed bởi thread khác.

Nghe có vẻ như những gì bạn muốn là chờ đợi chỉ khi một số điều kiện được giữ. Ví dụ:

synchronized (results) { 
    while (!results.hasResults()) { 
     // no results yet; wait for them 
     try { 
      results.wait(); 
     } catch (InterruptedException ie) { /* ignore */ } 
    } 
} 

Answer 3

Tôi thật sự khuyên bạn không nên phát minh lại bánh xe.

Giao diện Future của Java được thiết kế cho các kết quả chỉ có thể đến sau và lớp FutureTask triển khai giao diện này.

Để chuỗi đầu tiên có quyền truy cập vào Tương lai và tải chuỗi thứ hai để chạy FutureTask và tất cả nội dung này sẽ được xử lý cho bạn. Bạn cũng nhận được hỗ trợ timeout miễn phí.

Answer 4

Sử dụng một số điều kiện trước khi đi chờ đợi() và chắc chắn rằng điều kiện là chủ đề an toàn :)

class EMU{ 
    ResultVar RV; 
    Address my_address; 
    volatile boolean condition = true; 

    ResultVar findValue(String key){ 
     String tgt = findTarget(key); 
     sendRequest(tgt, key); 
     synchronized(RV){ 
      while(condition == true) 
      { 
       RV.wait(); 
      } 
     } 
     return RV; 
    } 

    Runnable Server = new Runnable(){ 
     public void run(){ 
      //code to receive connections. Assume object of type Request is read from the stream. 
      Request r = (Request) ois.readObject(); 
      if(r.requesterAddr.compareTo(my_address) == 0){ 
       String val = findVal(key); 
       RV.putVal(val); 
       synchronized(RV){ 
        condition = false; 
        RV.notify(); 
       } 
      } 
     } 

    };