cargo也是一個(gè)串行的消息隊(duì)列,類(lèi)似于queue,通過(guò)限制了worker數(shù)量,不再一次性全部執(zhí)行。當(dāng)worker數(shù)量不夠用時(shí),新加入的任務(wù)將會(huì)排隊(duì)等候,直到有新的worker可用。 cargo的不同之處在于,cargo每次會(huì)加載滿(mǎn)額的任務(wù)做為任務(wù)單元,只有任務(wù)單元中全部執(zhí)行完成后,才會(huì)加載新的任務(wù)單元。
cargo(worker, [payload])
代碼示例:
創(chuàng)建cargo實(shí)例:

監(jiān)聽(tīng):

增加新任務(wù):

結(jié)果:
