如何通過一個(gè)例子來描述線程wait和notify

這期內(nèi)容當(dāng)中小編將會(huì)給大家?guī)碛嘘P(guān)如何通過一個(gè)例子來描述線程wait和notify，文章內(nèi)容豐富且以專業(yè)的角度為大家分析和敘述，閱讀完這篇文章希望大家可以有所收獲。

場(chǎng)景：一個(gè)類中，一個(gè)是往容器中添加元素的方法，一個(gè)是返回容器大小的方法，現(xiàn)在又兩個(gè)線程，A線程調(diào)用添加方法，B線程調(diào)用返回容器大小方法，當(dāng)大小為5的時(shí)候，B線程提示并結(jié)束。

代碼可直接復(fù)制，運(yùn)行：

public class UseWaitAndNotify {
    volatile List list = new ArrayList();//這里為什么使用volatile，請(qǐng)看：https://my.oschina.net/u/4049911/blog/3121294  
    public void add(Object o) {
        list.add(o);
    }
    public int size() {
        return list.size();
    }
    public void useWaitAndNotify() {
        new Thread(new Runnable() {
            @Override
            public void run() {
                synchronized (this) {
                    System.out.println("size方法開始");
                    /**
                     * 這里必須得是不等于5，因?yàn)閯傞_始肯定不等于5，然后才會(huì)進(jìn)這個(gè)方法，執(zhí)行wait方法，這個(gè)線程就會(huì)在wait那等著。
                     * 然后cpu執(zhí)行另一個(gè)方法，當(dāng)另一個(gè)方法執(zhí)行等于5是，使用notify喚醒等待的線程（等待同一個(gè)鎖的線程）。
                     * 然后從wait方法開始往下執(zhí)行，到結(jié)束。
                     */
                    if(list.size()!=5) {
                        try {
                            wait();
                        } catch (InterruptedException e) {
                            // TODO Auto-generated catch block
                            e.printStackTrace();
                        }
                    }
                    System.out.println("size方法結(jié)束");
                }
            }
        }).start();
        synchronized (this) {
            System.out.println("add方法開始");
            for(int i=0;i<10;i++) {
                /**
                 *當(dāng)加入元素==5時(shí)，當(dāng)前線程就應(yīng)該停止，讓出cpu，讓cpu去執(zhí)行其他線程。
                 *那讓線程讓出cpu的方法有哪些呢：
                 *wait讓出線程，釋放鎖
                 *yield 讓出cpu，但不會(huì)釋放鎖
                 *join 插入其他線程，線程同步作用，在被調(diào)用線程未結(jié)束前，當(dāng)前線程將一直阻塞在join處
                 *
                 *我們使用wait
                 *
                 */
                list.add(new Object());
                if(i==4) {
                    /**
                     * 這里為什么使用notify后，又使用wait呢，就是上面這個(gè)方法的意思，使用notify，當(dāng)前線程是不會(huì)釋放鎖的，所以即使喚醒了其他
                     * 線程，其他線程拿不到鎖，也執(zhí)行不了。
                     * 也就是說如果下面不使用wait，當(dāng)list等于5的時(shí)候，另一個(gè)線程拿不到鎖，執(zhí)行不了，只有當(dāng)前線程釋放鎖，另一個(gè)線程才會(huì)拿到鎖執(zhí)行，
                     * 也就是說當(dāng)list的size等于10的時(shí)候，另一個(gè)線程才會(huì)停止
                     */
                    this.notify();
                    try {
                        this.wait();
                    } catch (InterruptedException e) {
                        // TODO Auto-generated catch block
                        e.printStackTrace();
                    }
                }
                System.out.println("add方法結(jié)束");
            }
        }
    }

    @Test
    public void test() {  
        //使用wait和notify實(shí)現(xiàn)  
        useWaitAndNotify();  
    }  
}

因?yàn)閣ait和notify只能在鎖中使用，所以需要加上synchronized鎖

上述就是小編為大家分享的如何通過一個(gè)例子來描述線程wait和notify了，如果剛好有類似的疑惑，不妨參照上述分析進(jìn)行理解。如果想知道更多相關(guān)知識(shí)，歡迎關(guān)注億速云行業(yè)資訊頻道。