wait notify方式

  1. package org.example.concurrency.test;
  3. import lombok.extern.slf4j.Slf4j;
  5. /**
  6.  * @author huskyui
  7.  */
  8. @Slf4j
  9. public class Test28 {
  10.     static final Object lock = new Object();
  11.     static boolean t2Runned = false;
  14.     public static void main(String[] args) {
  15.         Thread t1 = new Thread(()->{
  16.             synchronized (lock){
  17.                 while (!t2Runned){
  18.                     try {
  19.                         lock.wait();
  20.                     } catch (InterruptedException e) {
  21.                         e.printStackTrace();
  22.                     }
  23.                 }
  24.                 if (t2Runned){
  25.                     log.debug("t1");
  26.                 }else{
  27.                     log.debug("not t1");
  28.                 }
  29.             }
  30.         });
  32.         Thread t2 = new Thread(()->{
  33.             synchronized (lock){
  34.                 t2Runned = true;
  35.                 log.debug("t2");
  36.                 lock.notify();
  37.             }
  38.         });
  40.         t1.start();
  41.         t2.start();
  42.     }
  43. }

park unpark

  1. package org.example.concurrency.test;
  3. import lombok.extern.slf4j.Slf4j;
  5. import java.util.concurrent.locks.LockSupport;
  7. /**
  8.  * @author huskyui
  9.  */
  10. @Slf4j
  11. public class Test29 {
  12.     public static void main(String[] args) {
  13.         Thread t1 = new Thread(()->{
  14.             LockSupport.park();
  15.             log.debug("t1");
  16.         });
  17.         t1.start();
  18.         Thread t2 = new Thread(()->{
  19.             log.debug("t2");
  20.             LockSupport.unpark(t1);
  21.         });
  22.         t2.start();
  23.     }
  24. }