題圖：花啡，豆是買(mǎi)咖啡機(jī)送的，花是上周陽(yáng)朔旅游買(mǎi)的桂花，給它起了個(gè)名字，叫 Sunday。

咖啡味淡了一點(diǎn)點(diǎn)，多了一份桂花的清香。

本篇我們來(lái)研究一下 wait() notify() notifyAll() 。

DEMO1： wait() 與 notify()

public class Test {

    static class ThreadOne extends Thread {

        private Callback mCallback;

        @Override
        public void run() {
            work();
            if (mCallback != null) {
                mCallback.onResult(false);
            }
        }

        // 耗時(shí) 3s
        private void work() {
            System.out.println(" 正在查詢(xún)數(shù)據(jù)庫(kù) 1");
            long startTime = System.currentTimeMillis();
            while (true) {
                if (System.currentTimeMillis() - startTime < 3000) {
                    continue;
                }
                break;
            }
        }

        public void setCallback(Callback callback) {
            mCallback = callback;
        }

        public interface Callback {
            void onResult(boolean result);
        }
    }

    static class ThreadTest extends Thread {

        private Object mLock = new Object();

        private ThreadOne mThreadOne;

        @Override
        public void run() {
            workOne();
            System.out.println(" 根據(jù)結(jié)果繼續(xù)做其他事情 ");
        }

        private void workOne() {
            mThreadOne = new ThreadOne();
            mThreadOne.setCallback(new ThreadOne.Callback() {
                @Override
                public void onResult(boolean result) {
                    System.out.println(" 查詢(xún)數(shù)據(jù)庫(kù) 1 結(jié)束，:" + (result ? " 有數(shù)據(jù) " : " 無(wú)數(shù)據(jù) "));
                    synchronized (mLock) {
                        mLock.notify();
                        System.out.println("--ThreadTest 結(jié)束等待 --");
                    }
                }
            });
            mThreadOne.start();
            try {
                synchronized (mLock) {
                    System.out.println("--ThreadTest 進(jìn)入等待 --");
                    mLock.wait();
                }
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
    }

    public static void main(String[] var0) {
        ThreadTest threadTest = new ThreadTest();
        threadTest.start();
    }
}

DEMO1 輸出：

--ThreadTest 進(jìn)入等待--
正在查詢(xún)數(shù)據(jù)庫(kù) 1
查詢(xún)數(shù)據(jù)庫(kù) 1 結(jié)束，: 無(wú)數(shù)據(jù)
--ThreadTest 結(jié)束等待--
根據(jù)結(jié)果繼續(xù)做其他事情

注意：

使用 wait() 和 notify() 必須在獲得同步鎖后才能調(diào)用，若直接調(diào)用會(huì)報(bào) java.lang.IllegalMonitorStateException 錯(cuò)誤，因?yàn)闋顟B(tài)由同步鎖保護(hù)。

wait() 不同于 sleep() 的是 wait() 會(huì)釋放同步鎖。

因?yàn)?wait() 和 notify() 是基于同步鎖實(shí)現(xiàn)的，每個(gè)對(duì)象都有自己的同步鎖，所以 wait() 和 notify() 是 Object 的方法，而不是 Thread。

DEMO2，wait() 與 notifyAll()：

public class Test {

    private static Object mLock = new Object();

    static class MyThread extends Thread {

        String mName;
        Callback mCallback;

        public MyThread(String name){
            mName = name;
        }

        @Override
        public void run() {
            work();
            if (mCallback != null) {
                mCallback.onResult(false);
            }
        }

        // 耗時(shí) 3s
        private void work() {
            System.out.println(mName + " 等待 ");
            try {
                synchronized (mLock) {
                    mLock.wait();
                }
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }

        public void setCallback(Callback callback) {
            mCallback = callback;
        }

        public interface Callback {
            void onResult(boolean result);
        }
    }

    static class ThreadTest extends Thread {



        @Override
        public void run() {
            work("db1");
            work("db2");
            work("db3");

            try {
                sleep(2000);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }

            synchronized (mLock) {
                System.out.println(" 喚醒全部 ");
                mLock.notifyAll();
            }
        }

        private void work(String name) {
            final MyThread myThread = new MyThread(name);
            myThread.setCallback(new MyThread.Callback() {
                @Override
                public void onResult(boolean result) {
                    System.out.println(myThread.mName + " 回來(lái)了 ");
                }
            });
            myThread.start();
        }
    }

    public static void main(String[] var0) {
        ThreadTest threadTest = new ThreadTest();
        threadTest.start();
    }
}

DEMO2 輸出：

db1 等待
db3 等待
db2 等待
喚醒全部
db3 回來(lái)了
db1 回來(lái)了
db2 回來(lái)了

同一個(gè)對(duì)象的 wait() 方法可多次在不同的線程中調(diào)用，可讓不同的線程進(jìn)入等待（阻塞），可以一個(gè)一個(gè) notify()，也可以調(diào)用 notifyAll() 一次性全部喚醒。

來(lái)自：http://hackeris.me/2017/05/07/thread_base_1/

標(biāo)簽： 數(shù)據(jù)庫(kù)

版權(quán)申明：本站文章部分自網(wǎng)絡(luò)，如有侵權(quán)，請(qǐng)聯(lián)系：west999com@outlook.com
特別注意：本站所有轉(zhuǎn)載文章言論不代表本站觀點(diǎn)！
本站所提供的圖片等素材，版權(quán)歸原作者所有，如需使用，請(qǐng)與原作者聯(lián)系。