關(guān)于并發(fā)執(zhí)行異步任務(wù)，不阻塞

jenchih 2024-03-08

現(xiàn)有一個(gè)task表，里面存放了要執(zhí)行的class和method、args，隨時(shí)會(huì)新增
如何做到快速執(zhí)行消耗掉這些任務(wù)得到對(duì)應(yīng)的結(jié)果，并對(duì)結(jié)果保存

以前使用swoole時(shí)，
服務(wù)端: 啟動(dòng)一個(gè)tcp的服務(wù)
客戶(hù)端：定時(shí)器定時(shí)查詢(xún)task表，有數(shù)據(jù)，則在協(xié)程容器中，每個(gè)任務(wù)都創(chuàng)建一個(gè)協(xié)程客戶(hù)端，將數(shù)據(jù)投遞過(guò)去，服務(wù)端那邊負(fù)責(zé)執(zhí)行，并返回結(jié)果

現(xiàn)切換到webman，不知道如何操作才是最優(yōu)解

 985  3 2

3個(gè)回答

nitron 2024-03-08

自定義進(jìn)程
http://www.wtbis.cn/doc/webman/process.html

jenchih 2024-03-08

這個(gè)看過(guò)了，現(xiàn)有的想法，就是啟2個(gè)自定義進(jìn)程，一個(gè)進(jìn)程數(shù)開(kāi)多點(diǎn)，專(zhuān)門(mén)用來(lái)處理任務(wù)。另外一個(gè)自定義進(jìn)程就是一個(gè)定時(shí)器，獲取到數(shù)據(jù)并每個(gè)都投放過(guò)去？但是感覺(jué)還是會(huì)阻塞，其中一個(gè)耗時(shí)長(zhǎng)，后面等待執(zhí)行時(shí)間會(huì)很久
liong 2024-03-14

定時(shí)器是串行的