线程之间的通信

淡淡的烟草味﹌ 2023-08-17 16:08 97阅读 0赞

wait（）：将正在执行的线程停止，并存放到线程池。

notify（）：唤醒在线程池中等待的线程。

notify（）：唤醒全部。

package pers.Thread.conn;
    
    public class Tickets {
        private int size;
        private int num = 0;
        public Tickets(int size){
            this.size=size;
        }
        public int getSize() {
            return size;
        }
    
        public void setSize(int size) {
            this.size = size;
        }
    
        
        public int getNum() {
            return num;
        }
    
        public void setNum(int num) {
            this.num = num;
        }
    
        boolean flag = true;
    
        public synchronized void put() {
            if (flag) //还有剩余，等待
                try {
                    wait();
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
                num++;//等待结束后开始执行，增加票的操作
                System.out.println("存入第" + num + "号票");
                flag = true;//加票之后，有票，进入等待状态
                notify();//唤醒等待的线程
            
        }
        public synchronized void sell() {
            if (!flag) //没有剩余，等待
                try {
                    wait();
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }if(num>=1)
                System.out.println("卖出第" + num + "号票");
                flag = false;//减票之后，没有票，进入等待状态
                notify();//唤醒另外一个等待的线程
                if(num==size)num=size+1;
            }
        
    
    }

package pers.Thread.conn;
    
    public class Add extends Thread{
    Tickets t=null;
    public  Add(Tickets t){
        //为了保证卖出和增加的为统一数据对象
        this.t=t;
    }
    public void run(){
        while(t.getNum()<t.getSize())
            t.put();
    }
    }

package pers.Thread.conn;
    
    public class Sell extends Thread{
        Tickets t=null;
        public  Sell(Tickets t){
        //为了保证卖出和增加的为统一数据对象
            this.t=t;
        }
        public void run(){
            while(t.getNum()<=t.getSize())
                t.sell();
        }
    }

package pers.Thread.conn;
    
    public class Test {
    public static void main(String[] args) {
        Tickets t=new Tickets(15);
        new Add(t).start();//卖出和增加调用的为同一个对象
        new Sell(t).start();
        
    }
    }

转载于:https://www.cnblogs.com/zhai1997/p/11372721.html