Netty中的线程处理EventLoop
Netty是用什么來處理線程的?
一般線程池化模式為
- 從池的空閑任務(wù)列表中選擇一個Thread,指派它取運行一個已提交的任務(wù)
- 任務(wù)完成時,該Thread返回給該列表,使其可以重用
運行任務(wù)處理的在編程上的構(gòu)造通常稱作事件循環(huán),Netty使用EventLoop來描述。一個EventLoop將由一個永遠(yuǎn)不會變的Thread驅(qū)動,它可以被指派給多個channel,任務(wù)提交給Eventloop之后可以立即執(zhí)行或者調(diào)度執(zhí)行。任務(wù)的執(zhí)行順序是以先進(jìn)先出的順序執(zhí)行。
Netty是用什么做任務(wù)調(diào)度的?
jdk在concurrent包中的ScheduledExecutorService來執(zhí)行調(diào)度,它作為線程管理的一部分,會有額外的線程創(chuàng)建,但是當(dāng)有大量的任務(wù)被緊湊的調(diào)度的時候,這有可能成為瓶頸,EventLoop繼承了它,而且任務(wù)調(diào)度不存在這個問題。
要實現(xiàn)延遲執(zhí)行,只需調(diào)用schedule方法即可,要間隔一段時間,每次執(zhí)行,則調(diào)用scheduledAtFixedRate,想要取消調(diào)度則是通過返回的scheduledFuture調(diào)用cancel
EventLoop的執(zhí)行邏輯是怎樣的?
獲取當(dāng)前的執(zhí)行線程之后,判斷是不是分配給eventLoop的線程,如果是就直接執(zhí)行,否則放到隊列里面稍后執(zhí)行,這中模式就是Netty線程模式的卓越性,不用關(guān)心線程安全和同步相關(guān)問題
異步傳輸和同步傳輸對eventLoop來講線程分配有什么不同?
異步傳輸用的是少量的eventloop,以及與之對應(yīng)分配的Thread,通過一個線程來支撐多個channel(以此來實現(xiàn)少量線程支撐大量的channel),同步傳輸則是每個channel一個線程
總結(jié)
以上是生活随笔為你收集整理的Netty中的线程处理EventLoop的全部內(nèi)容,希望文章能夠幫你解決所遇到的問題。
- 上一篇: 你了解微服务架构么?
- 下一篇: log 框架 之间的关系