关于Java的Condition接口最佳理解方式

作者:JavaEdge. 时间:2021-05-28 19:06:35 

Condition就是实现了管程里面的条件变量。

Java 语言内置的管程里只有一个条件变量,而Lock&Condition实现的管程支持多个条件变量。 支持多个条件变量,能让代码可读性更好,实现也更容易。

例如,你看我这里实现一个阻塞队列,就需要两个条件变量:

  • 队列不空 空队列自然没有元素能出队队列不满

  • 队列已满,当然也不可有元素再入队

关于Java的Condition接口最佳理解方式

Lock和Condition实现的管程,线程等待和通知需要调用await()、signal()、signalAll(),它们的语义和wait()、notify()、notifyAll()相同。

  • Lock&Condition实现的管程里只能使用await()、signal()、signalAll()

  • synchronized实现的管程才能使用wait()、notify()、notifyAll()

如果在Lock&Condition实现的管程里调用wait()、notify()、notifyAll(),你距离离职就更近一步了。

Thread.sleep() V.S Condition.await()

Object.wait()和Condition.await()的原理是基本一致的,不同在于Condition.await()底层是调用LockSupport.park()实现阻塞当前线程。它在阻塞当前线程前,其实还做了:

  1. 把当前线程添加到条件队列

  2. 完全释放锁,即让state=0,然后才调用LockSupport.park()阻塞当前线程

JDK的Lock和Condition不过就是管程的一种实现,一般如何使用呢?

什么是同步与异步?

  • 同步 调用方需要等待结果

  • 异步 不需要等待结果

代码里如何实现异步?

  • 调用方创建一个子线程,在子线程中执行方法调用,即异步调用

  • 方法实现时,创建一个新的线程执行主要逻辑,主线程直接return,即异步方法。

异步场景挺多,比如TCP协议本身是异步的,日常的RPC调用,在TCP协议层面,发送完RPC请求后,线程不会等待RPC响应结果。

是不是好奇了,明明日常使用的RPC调用都是同步的呀?这到底是同步还是异步?

这肯定有人帮忙实现了异步转同步。比如RPC框架Dubbo,具体它是怎么做到的呢?

对于下面一个简单的RPC调用,默认情况下sayHello()是个同步方法,即执行service.sayHello(“dubbo”)时,线程会停下来等结果。

DemoService service = 初始化部分省略
String message = service.sayHello("dubbo");
System.out.println(message);

若此时dump调用线程的调用栈

关于Java的Condition接口最佳理解方式

发现调用线程阻塞了,线程状态是TIMED_WAITING。本来发送请求是异步的,但是调用线程却阻塞了,说明Dubbo帮我们做了异步转同步的事情。通过调用栈看到线程是阻塞在DefaultFuture.get(),所以Dubbo异步转同步的功能应该是通过DefaultFuture实现。

DefaultFuture.get()之前发生了什么呢:

关于Java的Condition接口最佳理解方式

我们的期望:

RPC返回结果前,阻塞调用线程,让调用线程等待
RPC返回结果后,唤醒调用线程,让调用线程重新执行

这就是经典的等待-通知机制,即管程的实现方案。

  • 看看Dubbo是怎么实现的。

关于Java的Condition接口最佳理解方式

来源:https://javaedge.blog.csdn.net/article/details/115953976

标签:Java,Condition,接口
0
投稿

猜你喜欢

  • SpringBoot搭配AOP实现自定义注解

    2022-04-07 01:21:59
  • 实例讲解Java读取一般文本文件和word文档的方法

    2023-11-13 05:09:53
  • C#多线程之线程同步

    2022-06-14 19:58:03
  • c#实现flv解析详解示例

    2022-06-10 22:57:21
  • Mybatis批量修改时出现报错问题解决方案

    2022-05-15 19:07:40
  • spring如何实现两个xml配置文件间的互调

    2021-06-07 20:50:15
  • ehcache模糊批量移除缓存的方法

    2023-01-11 12:30:37
  • Java7之forkjoin简介_动力节点Java学院整理

    2023-08-31 14:08:28
  • java数据结构之希尔排序

    2023-11-08 18:16:18
  • Java spring webmvc如何实现控制反转

    2023-03-12 06:35:56
  • Java 网络爬虫基础知识入门解析

    2022-05-16 02:39:06
  • Android Studio使用小技巧:提取方法代码片段

    2023-11-14 19:35:20
  • MyBatis-Plus找不到Mapper.xml文件的几种解决方法

    2023-11-24 03:37:52
  • C#中数组初始化与数组元素复制的方法

    2023-05-14 15:45:06
  • 详解C#中的session用法

    2022-10-29 22:03:13
  • 基于Spring的RPC通讯模型的使用与比较

    2022-04-22 01:18:18
  • java求余的技巧汇总

    2023-08-06 06:33:16
  • Java synchronized重量级锁实现过程浅析

    2023-10-25 14:10:17
  • Java下变量大小写驼峰、大小写下划线、大小写连线转换

    2022-04-19 15:20:18
  • Java实现树形结构的示例代码

    2023-07-30 01:05:19
  • asp之家 软件编程 m.aspxhome.com