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