JavaScript 任务池
JavaScript 任務(wù)池
線(xiàn)程池
在多線(xiàn)程語(yǔ)言中,我們通常不會(huì)隨意的在需要啟動(dòng)線(xiàn)程的時(shí)候去啟動(dòng),而是會(huì)選擇創(chuàng)建一個(gè)線(xiàn)程池。所謂線(xiàn)程池,本意其實(shí)就是(不止這些作用,其余作用可以自行查閱):
- 節(jié)省操作系統(tǒng)資源
- 限制最大線(xiàn)程數(shù)。
對(duì)于 JavaScript 來(lái)說(shuō) ,雖然不存在“啟動(dòng)線(xiàn)程”這種問(wèn)題,但我們還是可以通過(guò)類(lèi)似的思想,來(lái)限制我們做異步操作的數(shù)量。
分析
首先我們需要一個(gè)數(shù)組,用它來(lái)存儲(chǔ)尚未執(zhí)行的任務(wù),每個(gè)任務(wù)都是一個(gè)函數(shù),這個(gè)函數(shù)必須要返回一個(gè) Promise。
type Task = () =>Promise;const tasks: Task[] = []; 其次我們需要一個(gè)方法來(lái)進(jìn)行任務(wù)的添加。
function addTask(task: Task): void;最后我們需要一個(gè)函數(shù)來(lái)執(zhí)行我們所有的 task 。
而在這之前,我們還需要定義一個(gè)值 ,來(lái)定義同時(shí)執(zhí)行的異步任務(wù)的最大數(shù)量。
function execTasks(): void;實(shí)現(xiàn)
根據(jù)我們的分析 ,我們可以寫(xiě)下基礎(chǔ)的代碼如下 :
interface TaskPool { addTask(task: Task): void;}type Task = () =>Promise;function newTaskPool(max = 10): TaskPool { const tasks: Task[] = []; function addTask(task: Task): void { } function execTasks(): void { }} 新增任務(wù)非常簡(jiǎn)單,我們寫(xiě)出如下代碼填充 addTask。
function addTask(task: Task): void { tasks.push(task);}接下來(lái)就是重頭戲 。如何實(shí)現(xiàn) execTasks 方法來(lái)限制最大異步任務(wù)數(shù)量呢