(Java 高并发程序设计) 一篇文章带你深入了解重入锁的好搭档：Condition

Myth丶恋晨 2022-12-22 08:52 78阅读 0赞

已经学习了：

*  [一篇文章带你深入了解关键字 synchronized 的功能扩展：重入锁][synchronized]
 *  [一篇文章带你深入了解 Java 中线程的基本操作(wait/notify/suspend/resume/join/yeild)][Java _wait_notify_suspend_resume_join_yeild]

如果大家理解了`Object.wait()`方法和`Object.notify()`方法，就能很容易地理解Condition对象了。它与`wait()`方法和`notify()`方法的作用是大致相同的。但是`wait()`方法和`notify()`方法是与`synchronized`关键字合作使用的，而`Condition`是与重入锁相关联的。通过`lock`接口（重入锁就实现了这一接口）的`ConditionnewCondition()`方法可以生成一个与当前重入锁绑定的`Condition`实例。利用`Condition`对象，我们就可以让线程在合适的时间等待，或者在某一个特定的时刻得到通知，继续执行。`Condition`接口提供的基本方法如下：

![在这里插入图片描述][20201118202948800.png_pic_center]  
以上方法的含义如下：

*  `await()`方法会使当前线程等待，同时释放当前锁，当其他线程中使用`signal()`方法或者`signalAll()`方法时，线程会重新获得锁并继续执行。或者当线程被中断时，也能跳出等待。这和`Object.wait()`方法相似。
 *  `awaitUninterruptibly()`方法与`await()`方法基本相同，但是它并不会在等待过程中响应中断。
 *  `singal()`方法用于唤醒一个在等待中的线程，`singalAll()`方法会唤醒所有在等待中的线程。这和`Obejct.notify()`方法很类似。

import java.util.concurrent.locks.Condition;
    import java.util.concurrent.locks.ReentrantLock;
    
    public class ReenterLockCondition implements Runnable { 
        public static ReentrantLock lock = new ReentrantLock();
        //通过 lock 生成一个与之绑定的 Condition 对象
        public static Condition condition = lock.newCondition();
    
        @Override
        public void run() { 
            try { 
                lock.lock();
                //要求线程在 Condition 对象上进行等待
                condition.await();
                System.out.println("Thread is going on");
            } catch (InterruptedException e) { 
                e.printStackTrace();
            } finally { 
                lock.unlock();
            }
        }
    
        public static void main(String[] args) throws InterruptedException { 
            ReenterLockCondition r1 = new ReenterLockCondition();
            Thread t1 = new Thread(r1, "线程 r1");
            t1.start();
            System.out.println(Thread.currentThread().getName());
            Thread.sleep(2000);
            lock.lock();
            //主线程main发出通知，告知等待在Condition上的线程继续可以执行
            condition.signal();
            System.out.println(Thread.currentThread().getName());
            lock.unlock();
        }
    }

与`Object.wait()`方法和`notify()`方法一样，当线程使用`Condition.await()`方法时，要求线程持有相关的重入锁，在`Condition.await()`方法调用后，这个线程会释放这把锁。同理，在`Condition.signal()`方法调用时，也要求线程先获得相关的锁。在`signal()`方法调用后，系统会从当前`Condition`对象的等待队列中唤醒一个线程。一旦线程被唤醒，它会重新尝试获得与之绑定的重入锁，一旦成功获取，就可以继续执行了。因此，在`signal()`方法调用之后，一般需要释放相关的锁，让给被唤醒的线程，让它可以继续执行。比如，在本例中，第31行代码就释放了重入锁，如果省略第31行，那么，虽然已经唤醒了线程t1，但是由于它无法重新获得锁，因而也就无法真正的继续执行。

[synchronized]: https://blog.csdn.net/nanhuaibeian/article/details/109764779
[Java _wait_notify_suspend_resume_join_yeild]: https://blog.csdn.net/nanhuaibeian/article/details/109682317
[20201118202948800.png_pic_center]: /images/20221120/c453f614915b43068127e5b0a472318f.png