学步园

 --------------------------------------------------------------------------------</p> <p>等待线程（WaitThread ）</p> <p>package jintest;</p> <p>public class WaitThread extends Thread {</p> <p> public void run() {</p> <p> waiting();</p> <p> }</p> <p> private synchronized void waiting() {</p> <p> System.out.println("A--我开始等待");<br /> try {<br /> wait();<br /> } catch (InterruptedException e) {<br /> // TODO Auto-generated catch block<br /> e.printStackTrace();<br /> }<br /> System.out.println("A--我被通知了");</p> <p> }</p> <p> public void callup() {</p> <p> synchronized (this) {<br /> System.out.println("A--B一会就通知我");<br /> notifyAll();<br /> System.out.println("A--B刚刚通知我了");</p> <p> }</p> <p> }</p> <p>}</p> <p>--------------------------------------------------------------------------------</p> <p>通知线程（CallThread ）<br /> package jintest;</p> <p>public class CallThread extends Thread {</p> <p> private WaitThread waiter;</p> <p> public CallThread(WaitThread jinchun) {</p> <p> waiter = jinchun;<br /> }</p> <p> public void run() {<br /> System.out.println("B--我要去通知那个等待的线程");<br /> waiter.callup();<br /> System.out.println("B--我刚刚通知他了");</p> <p> }</p> <p>}</p> <p>--------------------------------------------------------------------------------</p> <p>16:33:46主线程（Test）</p> <p>package jintest;</p> <p>public class Test {</p> <p> public static void main(String args[]) {<br /> WaitThread A = new WaitThread();</p> <p> A.start();</p> <p> CallThread B = new CallThread(A);<br /> B.start();</p> <p> }</p> <p>}</p> <p>