黑马程序员技术交流社区

标题: 看线程的时候发Object对象中wait()和wait(long timeout)有什么作用 [打印本页]

---

作者: zhanghua    时间: 2011-11-16 17:43
标题: 看线程的时候发Object对象中wait()和wait(long timeout)有什么作用


在看线程的时候发Object对象中wait()和wait(long timeout)有什么作用呢？notify()方法是干什么的，notifyAll()又是干什么的
，这和线程有什么关系？

---

作者: 後天__牛永志    时间: 2011-11-16 17:59
上面的方法都是用在同步函数和同步代码块内部的。wait（），是是线程处于冻结状态。wait（Long timeout），是设定线程处于冻结状态超时时调用的方法。notify（）会唤醒（按进入冻结状态的顺序唤醒）冻结的线程进入执行状态，而notifyAll（）会唤醒所有在线程池中处于冻结状态的线程。具体和线程有什么关系，看毕老师的视频，多线程部分，讲解的很详细。
一个生产者和消费者的例子，希望对你有帮助
class Resouce{
        private String name;
        private int count;
        boolean flag=false;
        public synchronized void produce(String name){
                while(flag)
                        try{this.wait();}catch(Exception e){}//本方线程进入冻结状态
                this.name=name+count++;
               
                System.out.println(Thread.currentThread().getName()+"生产者"+"  ->"+this.name);
                flag=true;
                this.notifyAll();//唤醒所有处于冻结状态的线程
        }
        public synchronized void consumer(){
                while(!flag)
                        try{this.wait();}catch(Exception e){}//本方线程进入冻结状态
               
                System.out.println(Thread.currentThread().getName()+"消费者  --->"+this.name+this.name);
                flag=false;
                this.notifyAll();//唤醒所有处于冻结状态的线程
        }
}
class Producer implements Runnable{
        Resouce r;
        public Producer(Resouce r){
                this.r=r;
        }
        public void run(){
                while(true){
                        r.produce("商品");
                }
        }
}
class Consumer1 implements Runnable{
        private Resouce r;
        public Consumer1(Resouce r){
                this.r=r;
        }
        public void run(){
                while(true){
                        r.consumer();
                }
        }
}
public class TestTc {
        public static void main(String[] args) {
                Resouce r = new Resouce ();
                Producer p = new Producer (r);
                Consumer1 c = new Consumer1 (r);
                new Thread(p).start();
                new Thread(c).start();
               
        }

}
复制代码

---

欢迎光临 黑马程序员技术交流社区 (http://bbs.itheima.com/)

黑马程序员IT技术论坛 X3.2