Java多线程通信lock和wait

在Java多线程中有一对配合使用过的两个方法，来实现线程间通信的功能--lock和wait, 由于这个需要获得锁，所以必须结合synchronized一起使用。首先我们先看一个例子：

public class LockWait {
  
  static volatile List<String> itemContainer = new ArrayList<>();
  static Object obj = new Object();
  
  public static void main(String[] args) {
      Thread th1 = new Thread(() -> {
          synchronized (obj) {
              for (int i = 0; i < 10; i++) {
                  System.out.println("th1添加元素");
                  itemContainer.add(String.valueOf(i));
                  if (itemContainer.size() == 5) {
                      System.out.println("th1线程发出通知");
                      obj.notify();
                  }
              }
          }
      });
      
      Thread th2 = new Thread(() -> {
          synchronized (obj) {
              System.out.println("进入th2线程");
              if (itemContainer.size() != 5) {
                  try {
                      System.out.println("th2线程开始等待");
                      obj.wait();
                      System.out.println("th2线程等待结束");
                  } catch (InterruptedException e) {
                      e.printStackTrace();
                  }
                  System.out.println("th2线程结束");
              }
          }
          
      });
      
      th2.start();
      th1.start();
  }
}

输出结果如下：

进入th2线程
th2线程开始等待
th1添加元素
th1添加元素
th1添加元素
th1添加元素
th1添加元素
th1线程发出通知
th1添加元素
th1添加元素
th1添加元素
th1添加元素
th1添加元素
th2线程等待结束
th2线程结束

具体运行逻辑如下：

01.png

总结上面的运行结果，th2在wait的时候，th1可以持有锁。说明wait是释放锁，而notify不释放锁。

这样也就带来了一个弊端，无法实时的得到结果，就是说当List达到我们想要的结果的时候，th1线程一直还在持有锁，导致th2无法执行。

有没有更好办法呢？在Java中提供了一个CountDownLatch类：

public class CountDownLatchTest {
  
  public static void main(String[] args) {
      final List<String> itemContainer = new ArrayList<>();
      final CountDownLatch countDownLanch = new CountDownLatch(1);
      Thread th1 = new Thread(() -> {
          for (int i = 0; i < 10; i++) {
              try {
                  System.out.println("th1添加元素");
                  itemContainer.add(String.valueOf(i));
                  if (itemContainer.size() == 5) {
                      System.out.println("th1线程发出通知");
                      countDownLanch.countDown();
                  }
              } catch (Exception e) {
                  e.printStackTrace();
              }
              
          }
      });
      
      Thread th2 = new Thread(() -> {
          System.out.println("进入th2线程");
          if (itemContainer.size() != 5) {
              try {
                  System.out.println("th2线程开始等待");
                  countDownLanch.await();
                  System.out.println("th2线程等待结束");
              } catch (InterruptedException e) {
                  e.printStackTrace();
              }
              System.out.println("th2线程结束");
          }
          
      });
      
      th2.start();
      
      th1.start();
  }
}

运行结果：

进入th2线程
th1添加元素
th2线程开始等待
th1添加元素
th1添加元素
th1添加元素
th1添加元素
th1线程发出通知
th1添加元素
th2线程等待结束
th1添加元素
th2线程结束
th1添加元素
th1添加元素
th1添加元素

gzh.jpg

获得最新的博主文章，请关注上方公众号