亚洲乱码中文字幕综合,中国熟女仑乱hd,亚洲精品乱拍国产一区二区三区,一本大道卡一卡二卡三乱码全集资源,又粗又黄又硬又爽的免费视频

關(guān)于Java的Condition接口最佳理解方式

 更新時(shí)間:2023年05月09日 08:59:17   作者:JavaEdge.  
這篇文章主要介紹了關(guān)于Java的Condition接口最佳理解方式,Condition就是實(shí)現(xiàn)了管程里面的條件變量,Java?語(yǔ)言內(nèi)置的管程里只有一個(gè)條件變量,而Lock&Condition實(shí)現(xiàn)的管程支持多個(gè)條件變量,需要的朋友可以參考下

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

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

例如,你看我這里實(shí)現(xiàn)一個(gè)阻塞隊(duì)列,就需要兩個(gè)條件變量:

  • 隊(duì)列不空 空隊(duì)列自然沒(méi)有元素能出隊(duì)隊(duì)列不滿
  • 隊(duì)列已滿,當(dāng)然也不可有元素再入隊(duì)

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

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

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

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

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

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

JDK的Lock和Condition不過(guò)就是管程的一種實(shí)現(xiàn),一般如何使用呢?

什么是同步與異步?

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

代碼里如何實(shí)現(xiàn)異步?

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

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

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

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

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

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

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

發(fā)現(xiàn)調(diào)用線程阻塞了,線程狀態(tài)是TIMED_WAITING。本來(lái)發(fā)送請(qǐng)求是異步的,但是調(diào)用線程卻阻塞了,說(shuō)明Dubbo幫我們做了異步轉(zhuǎn)同步的事情。通過(guò)調(diào)用??吹骄€程是阻塞在DefaultFuture.get(),所以Dubbo異步轉(zhuǎn)同步的功能應(yīng)該是通過(guò)DefaultFuture實(shí)現(xiàn)。

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

我們的期望:

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

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

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

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

相關(guān)文章

最新評(píng)論