线程通讯

线程通讯：一个线程完成了自己的任务时，要通知另外一个线程去完成另外一个任务

生产者与消费者

　　通过产品建立关系

问题1：出现了线程安全问题。价格错乱。。（生产者的线程休眠10毫秒）

代码：

package com.java.test;

//产品
class product {
    public String name;
    public double price;
}

// 生产者
class producer extends Thread {

    public product p;

    public producer(product p) {
        this.p = p;
    }

    @Override
    public void run() {
        int i = 1;
        while (true) {
            synchronized ("生产者") {
                if (i % 2 == 0) {
                    p.name = "苹果";
                    try {
                        Thread.sleep(10);
                    } catch (InterruptedException e) {
                        // TODO Auto-generated catch block
                        e.printStackTrace();
                    }
                    p.price=6.5;
                } else {
                    p.name="香蕉";
                    p.price=2.0;
                }
                System.out.println("生产者生产出了："+p.name+"价格："+p.price);
                i++;
            }

        }
    }
}

// 消费者
class custom extends Thread {
    public product p;

    public custom(product p) {
        this.p = p;
    }

    @Override
    public void run() {
        int i = 1;
        while (true) {
            synchronized ("消费者") {
                System.out.println("消费者消费了："+p.name+"价格为："+p.price);

            }

        }
    }

}

public class producer_custom {
    
    public static void main(String[] args) {
        
        product p = new product();
        producer pr= new producer(p);
        custom c= new custom(p);
        
        pr.start();
        c.start();
        
        
        
    }
    
}

将上述对象改为  产品    则上述问题改变

需求，生产一个，消费一个

wait():　　等待　　如果线程执行了wait方法，那么该线程会进入等待的状态，等待状态下的线程，必须要被其他人调用notify()方法唤醒

notify()：　　唤醒　　唤醒等待的线程

wait与notify方法要注意的事项：

　　1.wait与notify方法是属于object对象的

　　2.wait与notify方法必须要在同步代码块或者是同步函数中才能使用

　　3.wait与notify方法必须由锁对象调用，

package com.java.test;

//产品
class product {
    public String name;
    public double price;
    boolean flag = false; // 标识 表示产品是否被生产
}

// 生产者
class producer extends Thread {

    public product p;

    public producer(product p) {
        this.p = p;
    }

    @Override
    public void run() {
        int i = 1;
        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;

                    }
                    i++;
                    p.flag = true;
                } else {
                    try {
                        
                        System.out.println("生产者生产出了：" + p.name + "价格：" + p.price);
                        p.wait();

                    } catch (InterruptedException e) {
                        e.printStackTrace();
                    }
                }

            }

        }
    }
}

// 消费者
class custom extends Thread {
    public product p;

    public custom(product p) {
        this.p = p;
    }

    @Override
    public void run() {
        int i = 1;
        while (true) {
            synchronized (p) {
                if (p.flag == true) {
                    System.out.println("消费者消费了：" + p.name + "价格为：" + p.price);
                    p.flag = false;
                } else {
                    //产品还没有生产
                    p.notify();
                }

            }

        }
    }

}

public class producer_custom {

    public static void main(String[] args) {

        product p = new product();
        producer pr = new producer(p);
        custom c = new custom(p);

        pr.start();
        c.start();

    }

}

守护线程（后台线程）：如果一个进程中只剩下了守护线程，那么守护线程也会死亡

一个线程默认都不是守护线程

package com.java.test;


class test_daemon extends Thread{
    
    public test_daemon(String name){
        super(name);
    }
    
    @Override
    public void run() {
        for (int i = 0; i <= 100; i++) {
            System.out.println("正在下载更新包"+"%"+i+"%");
            try {
                Thread.sleep(10);
            } catch (InterruptedException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
            }
            if(i==100){
                System.out.println("下载完成，准备安装。。。");
            }
        }
        

    }
}



public class daemon {
    public static void main(String[] args) {
        test_daemon t_d = new test_daemon("后台线程");
        t_d.setDaemon(true);
        t_d.start();
        
        for (int i = 0; i <=100; i++) {
            System.out.println(Thread.currentThread().getName()+":"+i);
        }
        
    }
}

join方法：加入

一个线程，如果执行了join语句，那么就是有新的线程加入，执行该语句的线程必须要让步给新加入的线程完成任务，然后下能继续执行。

package com.java.test;

class Man extends Thread{
    @Override
    public void run() {
        System.out.println("他追她");
        System.out.println("追到了");
        System.out.println("甜蜜中。。。");
        System.out.println("男方出轨了。。。。");
        System.out.println("女方开始挽留男方");
        
        Woman w = new Woman();
        w.start();
        
        try {
            w.join();
        } catch (InterruptedException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
        
        
        System.out.println("故事到这里就结束了");

    }
}


class Woman extends Thread{
    @Override
    public void run() {
        System.out.println("你这个渣男");
        System.out.println("终于看清你的面目了");
        System.out.println("分！！！");

    }
}



public class test_join {
    public static void main(String[] args) {
        Man m = new Man();
        m.start();
    }
}