使用Condition


使用ReentrantLock比直接使用synchronized更安全,可以替代synchronized进行线程同步。

但是,synchronized可以配合waitnotify实现线程在条件不满足时等待,条件满足时唤醒,用ReentrantLock我们怎么编写waitnotify的功能呢?

答案是使用Condition对象来实现waitnotify的功能。

我们仍然以TaskQueue为例,把前面用synchronized实现的功能通过ReentrantLockCondition来实现:

  1. class TaskQueue {
  2. private final Lock lock = new ReentrantLock();
  3. private final Condition condition = lock.newCondition();
  4. private Queue<String> queue = new LinkedList<>();
  5. public void addTask(String s) {
  6. lock.lock();
  7. try {
  8. queue.add(s);
  9. condition.signalAll();
  10. } finally {
  11. lock.unlock();
  12. }
  13. }
  14. public String getTask() {
  15. lock.lock();
  16. try {
  17. while (queue.isEmpty()) {
  18. condition.await();
  19. }
  20. return queue.remove();
  21. } finally {
  22. lock.unlock();
  23. }
  24. }
  25. }

可见,使用Condition时,引用的Condition对象必须从Lock实例的newCondition()返回,这样才能获得一个绑定了Lock实例的Condition实例。

Condition提供的await()signal()signalAll()原理和synchronized锁对象的wait()notify()notifyAll()是一致的,并且其行为也是一样的:

  • await()会释放当前锁,进入等待状态;

  • signal()会唤醒某个等待线程;

  • signalAll()会唤醒所有等待线程;

  • 唤醒线程从await()返回后需要重新获得锁。

此外,和tryLock()类似,await()可以在等待指定时间后,如果还没有被其他线程通过signal()signalAll()唤醒,可以自己醒来:

  1. if (condition.await(1, TimeUnit.SECOND)) {
  2. // 被其他线程唤醒
  3. } else {
  4. // 指定时间内没有被其他线程唤醒
  5. }

可见,使用Condition配合Lock,我们可以实现更灵活的线程同步。

小结

Condition可以替代waitnotify

Condition对象必须从Lock对象获取。

读后有收获可以支付宝请作者喝咖啡:

使用Condition - 图1