Condition就是實現(xiàn)了管程里面的條件變量。

Java 語言內(nèi)置的管程里只有一個條件變量，而Lock&Condition實現(xiàn)的管程支持多個條件變量。 支持多個條件變量，能讓代碼可讀性更好，實現(xiàn)也更容易。

例如，你看我這里實現(xiàn)一個阻塞隊列，就需要兩個條件變量：

• 隊列不空 空隊列自然沒有元素能出隊隊列不滿
• 隊列已滿，當(dāng)然也不可有元素再入隊

Lock和Condition實現(xiàn)的管程，線程等待和通知需要調(diào)用await()、signal()、signalAll()，它們的語義和wait()、notify()、notifyAll()相同。

• Lock&Condition實現(xiàn)的管程里只能使用await()、signal()、signalAll()
• synchronized實現(xiàn)的管程才能使用wait()、notify()、notifyAll()

如果在Lock&Condition實現(xiàn)的管程里調(diào)用wait()、notify()、notifyAll()，你距離離職就更近一步了。

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

Object.wait()和Condition.await()的原理是基本一致的，不同在于Condition.await()底層是調(diào)用LockSupport.park()實現(xiàn)阻塞當(dāng)前線程。它在阻塞當(dāng)前線程前，其實還做了：

1. 把當(dāng)前線程添加到條件隊列
2. 完全釋放鎖，即讓state=0，然后才調(diào)用LockSupport.park()阻塞當(dāng)前線程

JDK的Lock和Condition不過就是管程的一種實現(xiàn)，一般如何使用呢？

什么是同步與異步？

• 同步 調(diào)用方需要等待結(jié)果
• 異步 不需要等待結(jié)果

代碼里如何實現(xiàn)異步？

• 調(diào)用方創(chuàng)建一個子線程，在子線程中執(zhí)行方法調(diào)用，即異步調(diào)用
• 方法實現(xiàn)時，創(chuàng)建一個新的線程執(zhí)行主要邏輯，主線程直接return，即異步方法。

異步場景挺多，比如TCP協(xié)議本身是異步的，日常的RPC調(diào)用，在TCP協(xié)議層面，發(fā)送完RPC請求后，線程不會等待RPC響應(yīng)結(jié)果。

是不是好奇了，明明日常使用的RPC調(diào)用都是同步的呀？這到底是同步還是異步？

這肯定有人幫忙實現(xiàn)了異步轉(zhuǎn)同步。比如RPC框架Dubbo，具體它是怎么做到的呢？

對于下面一個簡單的RPC調(diào)用，默認(rèn)情況下sayHello()是個同步方法，即執(zhí)行service.sayHello(“dubbo”)時，線程會停下來等結(jié)果。

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

若此時dump調(diào)用線程的調(diào)用棧

發(fā)現(xiàn)調(diào)用線程阻塞了，線程狀態(tài)是TIMED_WAITING。本來發(fā)送請求是異步的，但是調(diào)用線程卻阻塞了，說明Dubbo幫我們做了異步轉(zhuǎn)同步的事情。通過調(diào)用棧看到線程是阻塞在DefaultFuture.get()，所以Dubbo異步轉(zhuǎn)同步的功能應(yīng)該是通過DefaultFuture實現(xiàn)。

DefaultFuture.get()之前發(fā)生了什么呢：

我們的期望：

RPC返回結(jié)果前，阻塞調(diào)用線程，讓調(diào)用線程等待
RPC返回結(jié)果后，喚醒調(diào)用線程，讓調(diào)用線程重新執(zhí)行

這就是經(jīng)典的等待-通知機(jī)制，即管程的實現(xiàn)方案。

• 看看Dubbo是怎么實現(xiàn)的。

到此這篇關(guān)于關(guān)于Java的Condition接口最佳理解方式的文章就介紹到這了,更多相關(guān)Java的Condition接口內(nèi)容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！

最新評論