听说过条件变量Condition吗

PhoenixZheng

发布于 2018-08-07 16:48:40

6260

发布于 2018-08-07 16:48:40

文章被收录于专栏：Phoenix的Android之旅Phoenix的Android之旅

上一次我们介绍了ReentrantLock和Synchronized的异同，这次我们来讲讲concurrent包下面的另外一个类，Condition。 Java的 java.util.concurrent 包提供了很多处理并发场景的类，Condition 就是其中一个。

我们花三分钟来了解Condition的作用吧~

场景举例

现在有个队列，线程A和线程B同时往里面写数据。 A从1写到3，B从4写到6，再交给A从7写到10，这样的场景我们要怎么处理问题呢？

首先想到的是并发加锁处理，然后就是我们要介绍的Condition了！

//初始化锁
final Lock lock = new ReentrantLock();

//第一个条件当A写到3
final Condition reachThreeCondition = lock.newCondition();
//第二个条件当B写到6
final Condition reachSixCondition = lock.newCondition();

获取Condition对象的方法很简单，对锁进行newCondition()操作就可以。我们直接以 ThreadA 举例，B的逻辑也是一样的。

Thread threadA = new Thread(new Runnable() {
  @Override
  public void run() {
      //需要先获得锁
      lock.lock();
      try {
          System.out.println("threadA start write");
          //A线程先写前3个数
          ...
          //输出到3时要signal，告诉B线程可以开始了
          reachThreeCondition.signal(); <====
      } finally {
          lock.unlock();
      }
      lock.lock();
      try {
          //等待B写到6的条件
          reachSixCondition.await(); <====
          System.out.println("threadA start write");
          //写剩余数字
          ...
      } catch (InterruptedException e) {
          e.printStackTrace();
      } finally {
          lock.unlock();
      }
  }

  });

B线程

Thread threadB = new Thread(new Runnable() {
  @Override
  public void run() {
      try {
          lock.lock();

          while (num.value <= 3) {
              //等待3写完的信号
              reachThreeCondition.await(); <====
          }
      } catch (InterruptedException e) {
          e.printStackTrace();
      } finally {
          lock.unlock();
      }
      try {
          lock.lock();
          //已经收到信号，开始写4，5，6
          System.out.println("threadB start write");
          ...
          //4，5，6写完，告诉A线程
          reachSixCondition.signal(); <====
      } finally {
          lock.unlock();
      }
  }

  });

代码解析

代码很简单， · 当我们需要某个条件满足才继续往下执行时，调用Condition的await()方法，此时线程会挂起，同时释放锁； · 其他并发线程完成条件后调用Condition的singnal()方法，其他等待这个Condition的线程则会获取锁并继续往下执行。

总结

当处理并发场景且需要等待某种条件时，一般都会将Condition对象作为成员变量。当调用await()方法后，当前线程会释放锁并在此等待，而其他线程调用Condition对象的signal()方法，通知当前线程后，当前线程才从await()方法返回，并且在返回前已经获取了锁。

聪明的你肯定意识到Condition和BlockingQueue会有某种联系。是的阻塞队列BlockingQueue的原理就是基于Condition实现的

我们下一次继续介绍BlockingQueue吧！欢迎关注订阅!

本文参与腾讯云自媒体分享计划，分享自微信公众号。

原始发表：2018-02-26，如有侵权请联系 cloudcommunity@tencent.com 删除

其他

本文分享自 Android每日一讲微信公众号，前往查看

如有侵权，请联系 cloudcommunity@tencent.com 删除。

本文参与腾讯云自媒体分享计划，欢迎热爱写作的你一起参与！

其他

登录后参与评论

0 条评论

热度