wait notify 版

  1. public class Test25 {
  2.     static final Object lock = new Object();
  3.     // 表示 t2 是否运行过
  4.     static boolean t2runned = false;
  6.     public static void main(String[] args) {
  7.         Thread t1 = new Thread(() -> {
  8.             synchronized (lock) {
  9.                 while (!t2runned) {
  10.                     try {
  11.                         lock.wait();
  12.                     } catch (InterruptedException e) {
  13.                         e.printStackTrace();
  14.                     }
  15.                 }
  16.                 log.debug("1");
  17.             }
  18.         }, "t1");
  21.         Thread t2 = new Thread(() -> {
  22.             synchronized (lock) {
  23.                 log.debug("2");
  24.                 t2runned = true;
  25.                 lock.notify();
  26.             }
  27.         }, "t2");
  29.         t1.start();
  30.         t2.start();
  31.     }
  32. }

Park Unpark 版

  1. public class Test26 {
  2.     public static void main(String[] args) {
  4.         Thread t1 = new Thread(() -> {
  5.             LockSupport.park();
  6.             log.debug("1");
  7.         }, "t1");
  8.         t1.start();
  10.         new Thread(() -> {
  11.             log.debug("2");
  12.             LockSupport.unpark(t1);
  13.         },"t2").start();
  14.     }
  15. }