Condition就是实现了管程里面的条件变量。 Java 语言内置的管程里只有一个条件变量,而Lock&Condition实现的管程支持多个条件变量。 支持多个条件变量,能让代码可读性更好,实现也更容易。例如,你看我这里实现一个阻塞队列,就需要两个条件变量:
Lock和Condition实现的管程,线程等待和通知需要调用await()、signal()、signalAll(),它们的语义和wait()、notify()、notifyAll()相同。
如果在Lock&Condition实现的管程里调用wait()、notify()、notifyAll(),你距离离职就更近一步了。
Object.wait()和Condition.await()的原理是基本一致的,不同在于Condition.await()底层是调用LockSupport.park()实现阻塞当前线程。它在阻塞当前线程前,其实还做了:
LockSupport.park()
阻塞当前线程JDK的Lock和Condition不过就是管程的一种实现,一般如何使用呢?
什么是同步与异步?
代码里如何实现异步?
异步场景挺多,比如TCP协议本身是异步的,日常的RPC调用,在TCP协议层面,发送完RPC请求后,线程不会等待RPC响应结果。
是不是好奇了,明明日常使用的RPC调用都是同步的呀?这到底是同步还是异步?
这肯定有人帮忙实现了异步转同步。比如RPC框架Dubbo,具体它是怎么做到的呢?
对于下面一个简单的RPC调用,默认情况下sayHello()是个同步方法,即执行service.sayHello(“dubbo”)时,线程会停下来等结果。
DemoService service = 初始化部分省略
String message = service.sayHello("dubbo");
System.out.println(message);
发现调用线程阻塞了,线程状态是TIMED_WAITING。本来发送请求是异步的,但是调用线程却阻塞了,说明Dubbo帮我们做了异步转同步的事情。通过调用栈看到线程是阻塞在DefaultFuture.get()
,所以Dubbo异步转同步的功能应该是通过DefaultFuture实现。
DefaultFuture.get()之前发生了什么呢:
我们的期望:
这就是经典的等待-通知机制,即管程的实现方案。