A股上市公司传智教育(股票代码 003032)旗下技术交流社区北京昌平校区

© 不二晨 金牌黑马   /  2018-10-16 09:21  /  890 人查看  /  3 人回复  /   0 人收藏 转载请遵从CC协议 禁止商业使用本文

wait():  等待   如果线程执行了wait方法,那么该线程会进入等待的状态,等待状态下的线程必须要被其他线程调用notify方法才能唤醒。
notify(): 唤醒    唤醒线程池等待线程其中的一个。
notifyAll() : 唤醒线程池所有等待 线程。

wait与notify方法要注意的事项:
1. wait方法与notify方法是属于Object对象 的。
2. wait方法与notify方法必须要在同步代码块或者是同步函数中才能 使用。
3. wait方法与notify方法必需要由锁对象调用。

线程通讯: 一个线程完成了自己的任务时,要通知另外一个线程去完成另外一个任务.
package lx3;

//产品类
class Product{
        String name;  //名字
        double price;  //价格
        boolean flag = false; //产品是否生产完毕的标识,默认情况是没有生产完成。
}

//生产者
class Producer extends Thread{
        Product  p ;          //产品
        public Producer(Product p) {
                this.p  = p ;
        }
       
        @Override
        public void run() {
                int i = 0 ;
                while(true){
                 synchronized (p) {
                        if(p.flag==false){
                                 if(i%2==0){
                                         p.name = "苹果";
                                         p.price = 6.5;
                                 }else{
                                         p.name="香蕉";
                                         p.price = 2.0;
                                 }
                                 System.out.println("生产者生产出了:"+ p.name+" 价格是:"+ p.price);
                                 p.flag = true;
                                 i++;
                                 p.notifyAll(); //唤醒消费者去消费
                        }else{
                                //已经生产 完毕,等待消费者先去消费
                                try {
                                        p.wait();   //生产者等待
                                } catch (InterruptedException e) {
                                        e.printStackTrace();
                                }
                        }                 
                }       
          }       
        }
}


//消费者
class Customer extends Thread{
        Product p;
        public  Customer(Product p) {
                this.p = p;
        }
       
        @Override
        public void run() {
                while(true){
                        synchronized (p) {       
                                if(p.flag==true){  //产品已经生产完毕
                                        System.out.println("消费者消费了"+p.name+" 价格:"+ p.price);
                                        p.flag = false;
                                        p.notifyAll(); // 唤醒生产者去生产
                                }else{
                                        //产品还没有生产,应该 等待生产者先生产。
                                        try {
                                                p.wait(); //消费者也等待了...
                                        } catch (InterruptedException e) {
                                                e.printStackTrace();
                                        }
                                }
                        }
                }       
        }
}

public class Demo5 {
       
        public static void main(String[] args) {
                Product p = new Product();  //产品
                //创建生产对象
                Producer producer = new Producer(p);
                //创建消费者
                Customer customer = new Customer(p);
                //调用start方法开启线程
                producer.start();
                customer.start();
                       
        }
       
}
线程的停止:
  1. 停止一个线程 我们一般都会通过一个变量去控制的。
  2. 如果需要停止一个处于等待状态下的线程,那么我们需要通过变量配合notify方法或者interrupt()来使用。

守护线程(后台线程):在一个进程中如果只剩下 了守护线程,那么守护线程也会死亡。
一个线程默认都不是守护线程。
  例: 模拟QQ下载更新包。
package lx3;

public class Dome1 extends Thread {
        public Dome1(String name) {
                super(name);
        }
        @Override
        public void run() {
                for(int i=1;i<=100;i++) {
                        System.out.println("更新包目前下载"+i+"%");
                        if(i==100) {
                                System.out.println("更新包下载完毕,准备安装..");
                        }
                        try {
                                Thread.sleep(100);
                        }catch(InterruptedException e) {
                                e.printStackTrace();
                        }
                }
               
        }

        public static void main(String[] args) {
                // TODO Auto-generated method stub
                Dome1 d=new Dome1("后台线程");
                d.setDaemon(true);
                d.start();
               
                for(int i=1;i<=100;i++) {
                        System.out.println(Thread.currentThread().getName()+":"+i);
                }

        }

}

---------------------
【转载】
作者:江南233244
原文:https://blog.csdn.net/qq_3913124 ... 277?utm_source=copy


3 个回复

倒序浏览
奈斯
回复 使用道具 举报
回复 使用道具 举报
您需要登录后才可以回帖 登录 | 加入黑马