加入收藏 | 设为首页 | 会员中心 | 我要投稿 汽车网 (https://www.0577qiche.cn/)- 科技、建站、经验、云计算、5G、大数据,站长网!
当前位置: 首页 > 教程 > 正文

Java的Condition接口最正确的理解方法

发布时间:2023-04-01 11:20:31 所属栏目:教程 来源:
导读:Condition就是实现了管程里面的条件变量。 Java 语言内置的管程里只有一个条件变量,而Lock&Condition实现的管程支持多个条件变量。 支持多个条件变量,能让代码可读性更好,实现也更容易。例如,你看我这里实现一个
Condition就是实现了管程里面的条件变量。 Java 语言内置的管程里只有一个条件变量,而Lock&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()实现阻塞当前线程。它在阻塞当前线程前,其实还做了:

把当前线程添加到条件队列
完全释放锁,即让state=0,然后才调用LockSupport.park()阻塞当前线程
JDK的Lock和Condition不过就是管程的一种实现,一般如何使用呢?

调用方创建一个子线程,在子线程中执行方法调用,即异步调用
方法实现时,创建一个新的线程执行主要逻辑,主线程直接return,即异步方法。
异步场景挺多,比如TCP协议本身是异步的,日常的RPC调用,在TCP协议层面,发送完RPC请求后,线程不会等待RPC响应结果。

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

DemoService service = 初始化部分省略
String message = service.sayHello("dubbo");
System.out.println(message);
若此时dump调用线程的调用栈

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

(编辑:汽车网)

【声明】本站内容均来自网络,其相关言论仅代表作者个人观点,不代表本站立场。若无意侵犯到您的权利,请及时与联系站长删除相关内容!

    推荐文章