突击并发编程JUC系列-Locksupport 与 Condition

突击并发编程JUC系列演示代码地址： https://github.com/mtcarpenter/JavaTutorial

Locksupport

JDK 中的 rt.jar 包里面的 LockSupport 是个工具类，当需要阻塞或唤醒一个线程的时候，都可以使用 LockSupport 工具类来完成相应工作。LockSupport定义了一组的公共静态方法，这些方法提供了最基本的线程阻塞和唤醒功能，而LockSupport 也成为构建同步组件的基础工具。LockSupport定义了一组以 park 开头的方法用来阻塞当前线程，以及 unpark(Thread thread)方法来唤醒一个被阻塞的线程。下面介绍LockSupport中的几个主要函数。

• void park(): 阻塞当前线程，如果调用 unpark(Thread thread) 方法或者当前线程被中断，才能从 park()方法返回。public class LockExample4 { public static void main(String[] args) throws Exception { Thread t1 = new Thread(new Runnable() { @Override public void run() { System.out.println(Thread.currentThread().getName() + "开始阻塞"); LockSupport.park(); System.out.println(Thread.currentThread().getName() + "阻塞已经被放开"); } }, "t1"); t1.start(); TimeUnit.SECONDS.sleep(3); new Thread(new Runnable() { @Override public void run() { System.out.println(Thread.currentThread().getName() + "开始"); LockSupport.unpark(t1); System.out.println(Thread.currentThread().getName() +"阻塞已经被放开"); } }, "t2").start(); } }运行结果：t1开始阻塞 t2开始 t2阻塞已经被放开 t1阻塞已经被放开
• void parkNanos(long nanos): 阻塞当前线程，最长不超过 nanos 纳秒，返回条件在park() 的基础上增加了超时返回。
• void parkUntil(long deadline): 阻塞当前线程，知道 deadline 时间 （从 1970 年开始到 deadline 时间的毫秒数）。
• void unpark(Thread thread): 唤醒处于阻塞状态的线程 thread。
• void park(Object blocker): 阻塞当前线程，blocker 用来标识当前线程在等待的对象。
• parkNanos(Object blocker, long nanos): 比 void park(Object blocker) 增加一个超时时间。
• parkUntil(Object blocker, long deadline): 比 void parkUntil(long deadline)  多一个阻塞当前对象。Locksupport 案例上手

Condition

任意一个 Java 对象，都拥有一组监视器方法（定义在java.lang.Object上），主要包括 wait()、wait(long timeout)、notify()以及notifyAll()方法，这些方法与synchronized同步关键字配合，可以实现等待/通知模式。

Condition接口也提供了类似Object的监视器方法，与Lock配合可以实现等待/通知模式，但是这两者在使用方式以及功能特性上还是有差别的。

2020-10-14_09-50-15.jpg

Condition 方法说明

void await() throws InterruptedException:当前线程进入等待状态直到被通知（signal）或中断，当前线程将进入运行状态且从 await() 方法 返回的情况。包括：

• 其他线程调用该 Condition 的 signal() 或 signalAll() 方法 ，而当前线程被选中唤醒public class LockExample5 { public static void main(String[] args) throws Exception { Lock lock = new ReentrantLock(); Condition condition = lock.newCondition(); Thread t1 = new Thread(new Runnable() { @Override public void run() { lock.lock(); try { System.out.println(Thread.currentThread().getName() + "开始阻塞"); condition.await(); System.out.println(Thread.currentThread().getName() + "阻塞已经被放开"); } catch (InterruptedException e) { } finally { lock.unlock(); } } }, "t1"); t1.start(); TimeUnit.SECONDS.sleep(3); new Thread(new Runnable() { @Override public void run() { lock.lock(); try { System.out.println(Thread.currentThread().getName() + "开始阻塞"); condition.signalAll(); System.out.println(Thread.currentThread().getName() + "阻塞已经被放开"); } finally { lock.unlock(); } } }, "t2").start(); } }运行结果：t1开始阻塞 t2开始阻塞 t2阻塞已经被放开 t1阻塞已经被放开
  • 其他线程（调用 Interrupt()方法）中断当前线程
  • 如果当前等待线程从 await() 方法返回，那么表明该线程已经获取了Condition 对象所对应的锁
• void awaitUninterruptibly():当前线程进入等待状态被通知，从方法返回名称上可以看出该方法对中断不敏感
• long awaitNanos(long nanosTimeout):当前线程进入等待状态直到被通知，中断或者超时。返回值表示剩余的时间，如果在 nanosTimeout 纳秒之前被唤醒，那么返回值就是 （nanosTimeout-实际耗时）。如果返回 0 或者负数，那么可以认定已经超时了
• boolean awaitUntil(Date deadline):当前线程进入等待状态知道被通知、中断或者到某一个时间。如果没有到指定时间就被通知，方法返回 true ，否则，表示到了指定时间，方法返回 false。
• void signal():唤醒一个等待在 Condition 上的线程，该线程从等待方法返回前必须获得与 Condition 相关的锁
• void signalAll():唤醒所有等待在 Condition 上的线程，能够从等待方法返回的线程必须获得与 Condition相关的锁Condition 案例上手

欢迎关注公众号 山间木匠 ， 我是小春哥，从事 Java 后端开发，会一点前端、通过持续输出系列技术文章以文会友，如果本文能为您提供帮助，欢迎大家关注、点赞、分享支持，我们下期再见！