<p>题图：花啡，豆是买咖啡机送的，花是上周阳朔旅游买的桂花，给它起了个名字，叫 Sunday。</p>    <p>咖啡味淡了一点点，多了一份桂花的清香。</p>    <p>本篇我们来研究一下 wait() notify() notifyAll() 。</p>    <p>DEMO1： wait() 与 notify()</p>    <pre>  <code class="language-java">public class Test {        static class ThreadOne extends Thread {            private Callback mCallback;            @Override          public void run() {              work();              if (mCallback != null) {                  mCallback.onResult(false);              }          }            // 耗时 3s          private void work() {              System.out.println(" 正在查询数据库 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(" 根据结果继续做其他事情 ");          }            private void workOne() {              mThreadOne = new ThreadOne();              mThreadOne.setCallback(new ThreadOne.Callback() {                  @Override                  public void onResult(boolean result) {                      System.out.println(" 查询数据库 1 结束，:" + (result ? " 有数据 " : " 无数据 "));                      synchronized (mLock) {                          mLock.notify();                          System.out.println("--ThreadTest 结束等待 --");                      }                  }              });              mThreadOne.start();              try {                  synchronized (mLock) {                      System.out.println("--ThreadTest 进入等待 --");                      mLock.wait();                  }              } catch (InterruptedException e) {                  e.printStackTrace();              }          }      }        public static void main(String[] var0) {          ThreadTest threadTest = new ThreadTest();          threadTest.start();      }  }</code></pre>    <p>DEMO1 输出：</p>    <pre>  <code class="language-java">--ThreadTest 进入等待--  正在查询数据库 1  查询数据库 1 结束，: 无数据  --ThreadTest 结束等待--  根据结果继续做其他事情</code></pre>    <p>注意：</p>    <p>使用 wait() 和 notify() 必须在获得同步锁后才能调用，若直接调用会报 java.lang.IllegalMonitorStateException 错误，因为状态由同步锁保护。</p>    <p>wait() 不同于 sleep() 的是 wait() 会释放同步锁。</p>    <p>因为 wait() 和 notify() 是基于同步锁实现的，每个对象都有自己的同步锁，所以 wait() 和 notify() 是 Object 的方法，而不是 Thread。</p>    <p>DEMO2，wait() 与 notifyAll()：</p>    <pre>  <code class="language-java">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);              }          }            // 耗时 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 + " 回来了 ");                  }              });              myThread.start();          }      }        public static void main(String[] var0) {          ThreadTest threadTest = new ThreadTest();          threadTest.start();      }  }</code></pre>    <p>DEMO2 输出：</p>    <pre>  <code class="language-java">db1 等待  db3 等待  db2 等待  唤醒全部  db3 回来了  db1 回来了  db2 回来了</code></pre>    <p>同一个对象的 wait() 方法可多次在不同的线程中调用，可让不同的线程进入等待（阻塞），可以一个一个 notify()，也可以调用 notifyAll() 一次性全部唤醒。</p>    <p> </p>    <p>来自：http://hackeris.me/2017/05/07/thread_base_1/</p>    <p> </p>