爪哇 - obj.notify（）似乎並沒有工作

Question

在我的Java代碼threadB創建NB *的ThreadA和等待，直到MyObj中價值將等於NB。 myobj最初等於0，並且每個線程A增加它，當它變得等於nb最後一個線程A通知ThreadB。

運行程序時，threadB不會被通知並且不會繼續運行。有人能告訴我這段代碼中的問題在哪裏？

public class Myclass { 
    static Long myobj = new Long(0); 
    static int nb = 1; 

    public static void main(String[] args) { 

     ThreadA[] threadA = new ThreadA[nb]; 
     ThreadB threadB = new ThreadB(threadA); 
    } 
} 

public class ThreadA extends Thread { 
    public ThreadA() { 
     this.start(); 
    } 

    public void run() { 
     // do lot of computation 
     Myclass.myobj = Myclass.myobj + 1; 
     if (Myclass.myobj.intValue() == Myclass.myobj.nb) { 
      synchronized (Myclass.myobj) { 
       Myclass.myobj.notify(); 
      } 
     } 
    } 
} 

public class ThreadB extends Thread { 
    ThreadA[] threadA; 

    public ThreadB(ThreadA[] threadA) { 
     this.threadA = threadA; 
     this.start(); 
    } 

    public void run() { 
     for (int i = 0; i < threadA.length; i++) { 
      threadA[i] = new ThreadA(); 
     } 

     synchronized (Myclass.myobj) { 
      while (Myclass.myobj.intValue() != Myclass.myobj.nb) { 
       Myclass.myobj.wait(); 
      } 
     } 
    } 
} 

Answer 1

你在等待一個對象，並通知在不同的一個，因爲ThreadA中分配一個新的對象來Myclass.myobj並通知這個新對象。

使用專用的鎖對象，並確保每個對myObj的訪問都由此鎖對象保護。

或者更好的是，使用java.util.concurrent包中的更高級併發抽象。

Answer 2

我被所有可能是錯誤的東西所困惑，但沒有引起問題。

真正的問題是，

if (Myclass.myobj.intValue() == Myclass.myobj.nb) 

永遠不會每到這個被稱爲myobj < nb

---

我怎麼會寫這樣的代碼時爲真實？

int nb = .... 

ExecutorService es = Executors.newFixedThreadPool(nb) 
for (int i = 0; i < nb; i++) 
    es.submit(new Runnable() { 
     @Override 
     public void run() { 
      // do lot of computation 
     } 
    }); 
es.shutdown(); 
es.awaitTermination(1, TimeUnit.HOURS); 

---

有這麼多的事情，以改善這裏我覺得有必要列出它們

• 不使用正確的格式。
• 確實提供可能編譯的代碼
• 不鎖定可變字段。這不會做你期望的，因爲你每次都會鎖定不同的對象。
• 當您的意思是使用long時，請勿使用Long。在這個原因中，你似乎想要使用int。
• 不會創建new Long(0)，因爲您可以使用更高效的自動裝箱。如果你這樣做，不要把它用作鎖定的對象。
• 請勿在線程之間使用可變的static字段。
• 不延伸Thread。創建一個傳遞給線程的Runnable。
• 不要在構造函數中啓動線程。
• 不使用數組將線程傳遞給另一個線程。尤其是在該線程開始之前它不會被設置。
• 只讀取/檢查同步塊內的受保護值。
• 我不會使用一個線程來創建另一個線程，這個線程被傳回原始線程。

但是，您的基本問題是您正在等待與您通知的對象不同的對象。

synchronized(Myclass.myobj){ // lock the object you might be waiting on. 
    Myclass.myobj=Myclass.myobj+1; // change this to another object. 
    Myclass.myobj.notify(); // notify a different object. 
}