Java多线程的wait()和notify()例子。

示例代码1：

　　package com.pinfo.test;

　　public class ThreadTest {

　　/**

　　* @param args

　　*/

　　public static void main(String[] args) {

　　String lock = "lock";

　　MyThread myThread = new MyThread(lock);

　　Thread t1 = new Thread(myThread);

　　t1.start();

　　try {

　　//确保线程t1先执行

　　Thread.sleep(2000);

　　} catch (InterruptedException e) {

　　e.printStackTrace();

　　}

　　SubThread sub = new SubThread(lock);

　　Thread t2 = new Thread(sub);

　　t2.start();

　　}

　　}

　　class MyThread implements Runnable{

　　String lock;

　　public MyThread(String lock){

　　this.lock = lock;

　　}

　　public void run(){

　　int i = 0;

　　//使用lock对象作为监视器

　　synchronized(lock){

　　while(i++<20){

　　try {

　　//每次暂停500毫秒是为了更好地看到效果

　　Thread.sleep(500);

　　System.out.println("The first thread.-->"+i);

　　if(i==10){

　　//调用lock监视器的wait()方法，通知本线程释放监视器,本线程等待

　　//其他也使用lock对象作为监视器的线程唤醒的时候，本线程得以继续运行

　　lock.wait();

　　//下面的wait(long timeout)表示：若等待5秒后还没有别的线程来唤醒的话，则本线程继续执行

　　//lock.wait(5000);

　　}

　　} catch (InterruptedException e) {

　　e.printStackTrace();

　　}

　　}

　　}

　　}

　　}

　　class SubThread implements Runnable{

　　String lock;

　　public SubThread(String lock){

　　this.lock = lock;

　　}

　　public void run(){

　　int i = 0;

　　//这个线程也使用lock对象作为监视器

　　synchronized(lock){

　　while(i<10){

　　i++;

　　try {

　　Thread.sleep(500);

　　System.out.println("The second thread.-->"+i);

　　} catch (InterruptedException e) {

　　e.printStackTrace();

　　}

　　}

　　//调用lock对象的notify()方法，唤醒同一对象监视器中调用wait的第一线程

　　//或者调用notifyAll()方法，唤醒同一对象监视器中调用wait的所有线程，具有最高优先级的线程首先被唤醒并执行

　　lock.notify();

　　}

　　}

　　}

　　示例代码2：

　　package com.pinfo.test;

　　public class ThreadTest {

　　/**

　　* @param args

　　*/

　　public static void main(String[] args) {

　　MyThread myThread = new MyThread();

　　//使用Runnable实现类创建线程

　　Thread t1 = new Thread(myThread);

　　//启动线程

　　t1.start();

　　try {

　　//确保线程t1先执行

　　Thread.sleep(2000);

　　} catch (InterruptedException e1) {

　　e1.printStackTrace();

　　}

　　int i = 0;

　　//主线程使用myThread对象作为监视器

　　synchronized(myThread){

　　while(++i<=10){

　　try {

　　Thread.sleep(500);

　　System.out.println("The main thread.-->"+i);

　　} catch (InterruptedException e) {

　　// TODO Auto-generated catch block

　　e.printStackTrace();

　　}

　　}

　　//调用监视器的notify()方法唤醒t1线程

　　myThread.notify();

　　}

　　}

　　}

　　class MyThread implements Runnable{

　　public void run(){

　　int i = 0;

　　//使用对象本身this作为监视器(与主线程的监视器为同一个对象)

　　synchronized(this){

　　while(i++<20){

　　try {

　　Thread.sleep(500);

　　System.out.println("The sub thread.-->"+i);

　　if(i==10){

　　//释放监视器锁，阻塞等待...

　　this.wait();

　　}

　　} catch (InterruptedException e) {

　　e.printStackTrace();

　　}

　　}

　　}

　　}

　　}