首頁(yè) 猿問(wèn) 由于接收超時(shí)和任務(wù)執(zhí)行器不協(xié)調(diào)而導(dǎo)...

由于接收超時(shí)和任務(wù)執(zhí)行器不協(xié)調(diào)而導(dǎo)致內(nèi)存泄漏

Java

江戶(hù)川亂折騰 2023-07-13 13:57:01

我正在瀏覽 spring 集成參考文檔，在第 10.1.8 節(jié)異步輪詢(xún)中，它寫(xiě)道，不協(xié)調(diào)的 conf 可能會(huì)導(dǎo)致內(nèi)存泄漏。根據(jù)下面的文檔，conf 不協(xié)調(diào)：<int:channel id="publishChannel">? ? <int:queue /></int:channel><int:service-activator input-channel="publishChannel" ref="myService">? ? <int:poller receive-timeout="5000" task-executor="taskExecutor" fixed-rate="50" /></int:service-activator><task:executor id="taskExecutor" pool-size="20" />我在理解本節(jié)時(shí)遇到困難，因?yàn)樗鼘?xiě)的是每秒將執(zhí)行 4 個(gè)線(xiàn)程，因?yàn)槊總€(gè)線(xiàn)程將等待 250 毫秒，并且任務(wù)將以每秒 20 個(gè)的速度添加。任務(wù)執(zhí)行器是否應(yīng)該只分配 1 個(gè)線(xiàn)程來(lái)等待傳入消息，并且應(yīng)該啟動(dòng)最大線(xiàn)程以防隊(duì)列中有足夠的任務(wù)？另外，為什么每秒只有 4 個(gè)線(xiàn)程執(zhí)行，如果任務(wù)花費(fèi)超過(guò) 250 毫秒怎么辦？如果它太簡(jiǎn)單并且我錯(cuò)過(guò)了一些微不足道的東西，請(qǐng)道歉。

查看完整描述

1 回答

瀟湘沐

TA貢獻(xiàn)1816條經(jīng)驗(yàn) 獲得超6個(gè)贊

這<task:executor id="taskExecutor" pool-size="20" />是一個(gè)無(wú)界的任務(wù)隊(duì)列。這是默認(rèn)的。

這task-executor="taskExecutor" fixed-rate="50"意味著不會(huì)阻塞調(diào)度程序的線(xiàn)程，并且調(diào)度程序每 50 毫秒啟動(dòng)一次新的輪詢(xún)！它的發(fā)生確實(shí)與publishChannel內(nèi)容無(wú)關(guān)。我的意思是新任務(wù)總是被放入taskExecutor隊(duì)列中。

如果下游進(jìn)程確實(shí)足夠長(zhǎng)，則20執(zhí)行器的所有線(xiàn)程都會(huì)很忙，并且任務(wù)的內(nèi)部隊(duì)列將會(huì)增長(zhǎng)。這就是內(nèi)存泄漏最嚴(yán)重的地方。

1 秒/ 50 毫秒 = 每秒 20 個(gè)任務(wù)。

如果中沒(méi)有消息publishChannel，我會(huì)說(shuō)任務(wù)執(zhí)行器中的所有線(xiàn)程都將忙于等待 5 秒超時(shí)。那么，任務(wù)的完成率是多少呢？20 active tasks / 5000 millis to wait for their finish = 4 per second。

這個(gè)故事與4 個(gè)線(xiàn)程無(wú)關(guān)，而是在實(shí)際情況下我們能夠以多快的速度耗盡任務(wù)隊(duì)列。

反對(duì) 回復(fù) 2023-07-13