Object obj = new Object();
obj.wait();

Object obj = new Object();
obj.notify();

Object obj = new Object();
obj.notifyAll();

public class resourse {
    private Integer number = 0 ;
    /**
     * 用if為啥不行
     * 1：首先一點(diǎn)我們要搞清楚 wait操作會(huì)釋放鎖
     * 2：想想這種情況,當(dāng)一個(gè)生產(chǎn)者線程執(zhí)行的時(shí)候 if number！=0 (此時(shí)的number為1 ) 就會(huì)發(fā)生阻塞 這時(shí)候
     * 釋放出鎖 這時(shí)候又一個(gè)生產(chǎn)者進(jìn)程進(jìn)來又會(huì)被wait住.然后一個(gè)生產(chǎn)者進(jìn)程進(jìn)來，消費(fèi)了一個(gè) 但是notifyall 將所有的進(jìn)程
     * 都解開了 。。那兩個(gè)生產(chǎn)者進(jìn)程就會(huì)直接運(yùn)行if后面的東西并沒有被拉回來重新判斷一下。這樣就造成了number的值變成2.同理number
     * 變成負(fù)數(shù)也是有可能的(兩個(gè)消費(fèi)者進(jìn)程先進(jìn)來都堵塞).
     *
     *
     *
     *
     * @throws Exception
     */
    public synchronized void  produce () throws Exception
    {
//        判斷  這里用while 用if多與兩個(gè)線程容易出錯(cuò)
//        不等于0就要等待消費(fèi)者消費(fèi)完
         if(number!=0)
         {
             this.wait();
         }
//         干活
        number++;
        System.out.println(Thread.currentThread().getName() + "的資源數(shù)為：" + number.toString());
//        釋放
        this.notifyAll();
    }
//wait操作會(huì)釋放鎖
    public synchronized void consumer () throws Exception
    {
        //    等于零就要等待生產(chǎn)者生產(chǎn)
        if (number == 0)
        {
            this.wait();
        }
//        消費(fèi)
        number--;
        System.out.println(Thread.currentThread().getName() + "的資源數(shù)為：" + number.toString());
//        釋放
        this.notifyAll();
    }
}

public class main {
    public static void main (String[] args) {
        resourse resourse = new resourse();
            new Thread(()->{
                try{
                    for (int i=0 ; i<100;i++)
                    resourse.produce();
                }catch (Exception e)
                {
                    e.printStackTrace();
                }
            }).start();
        new Thread(()->{
            try{
                for (int i=0 ; i<100;i++)
                resourse.produce();
            }catch (Exception e)
            {
                e.printStackTrace();
            }
        }).start();
        new Thread(()->{
            try{
                for (int i=0 ; i<100;i++)
                    resourse.consumer();
            }catch (Exception e)
            {
                e.printStackTrace();
            }
        }).start();
        new Thread(()->{
            try{
                for (int i=0 ; i<100;i++)
                resourse.consumer();
            }catch (Exception e)
            {
                e.printStackTrace();
            }
        }).start();
    }
}