快捷導(dǎo)航

JavaScript模擬隊(duì)列的用法詳解

更新時(shí)間：2023年10月09日 08:25:24 作者：霧戀

我原本以為JavaScript是不能寫(xiě)隊(duì)列的,最近發(fā)現(xiàn)JavaScript是可以模擬隊(duì)列的,并且花樣還挺多,所以本文將給大家介紹JavaScript模擬隊(duì)列的基礎(chǔ)寫(xiě)法用法,需要的朋友可以參考下

場(chǎng)景

場(chǎng)景一：

有幾百條數(shù)據(jù)需要傳遞給后端，但是后端每次最多只能接收10條數(shù)據(jù)

場(chǎng)景二：

在彈出第一個(gè)彈框并關(guān)閉后再?gòu)椀诙€(gè)彈窗（或者廣告一類(lèi)的）

我想這些需求大家應(yīng)該都了解過(guò)，或者遇到過(guò)，我們可能第一反應(yīng)是通過(guò)定時(shí)器或者Promise來(lái)處理，現(xiàn)在我告訴你完全可以通過(guò)隊(duì)列的方式來(lái)處理。我會(huì)寫(xiě)一些示例，如果運(yùn)用到工作中請(qǐng)根據(jù)自己的需求進(jìn)行修改即可。

說(shuō)明

JavaScript 隊(duì)列(Queue)是一種先進(jìn)先出(FIFO)的數(shù)據(jù)結(jié)構(gòu)，它用于存儲(chǔ)按順序排列的元素，并支持插入新元素和刪除元素的操作。隊(duì)列在計(jì)算機(jī)科學(xué)中有著廣泛的應(yīng)用，例如在操作系統(tǒng)中實(shí)現(xiàn)任務(wù)調(diào)度、在數(shù)據(jù)壓縮中使用哈夫曼編碼等。在JavaScript中，隊(duì)列也常用于實(shí)現(xiàn)異步編程和控制流程。 JavaScript隊(duì)列通常可以通過(guò)內(nèi)置的Array對(duì)象實(shí)現(xiàn)，或者使用第三方庫(kù)如queue-lib。Array對(duì)象提供了push()和shift()方法，可以模擬隊(duì)列的入隊(duì)和出隊(duì)操作。

簡(jiǎn)單隊(duì)列

我們從下面的模擬隊(duì)列中可以看出，我們?cè)趫?zhí)行的時(shí)候makeRequest（模擬請(qǐng)求）是依次開(kāi)始執(zhí)行，那么我們想同時(shí)執(zhí)行多個(gè)請(qǐng)求呢？我們想間隔一段時(shí)間在發(fā)送請(qǐng)求呢？那我們接到看下面這個(gè)示例。

class RequestQueue {
    constructor() {
        this.queue = []; // 請(qǐng)求隊(duì)列
        this.running = 0; // 當(dāng)前正在運(yùn)行的請(qǐng)求數(shù)量
    }
    // 將請(qǐng)求添加到隊(duì)列中
    enqueue(request) {
        this.queue.push(request);
        this.run(); // 檢查是否可以運(yùn)行新的請(qǐng)求
    }
    // 檢查并運(yùn)行請(qǐng)求
    run() {
        if (this.running !== 0 || !this.queue.length) return;
        const request = this.queue.shift();
        this.execute(request);
        this.running++;
    }
    // 執(zhí)行請(qǐng)求
    execute(request) {
        request().finally(() => {
            this.running--;
            if (this.queue.length <= 0) return;
            this.run();
        });
    }
}
// 模擬一個(gè)異步請(qǐng)求
function makeRequest(id) {
    return new Promise((resolve) => {
        console.log(`正在發(fā)送請(qǐng)求 ${id}`);
        setTimeout(() => {
            console.log(`請(qǐng)求 ${id} 完成`);
            resolve(id);
        }, 1000);
    })
}
// 創(chuàng)建請(qǐng)求隊(duì)列并添加10個(gè)請(qǐng)求
const queue = new RequestQueue(1, 100);
for (let i = 1; i <= 10; i++) {
    queue.enqueue(async () => await makeRequest(i));
};

完整隊(duì)列

我們從該隊(duì)列中可以看出，我們可以去控制自己的并發(fā)量以及間隔時(shí)間了，那么我們?cè)诳紤]下。如果隊(duì)列執(zhí)行完成了，我們?cè)趺粗滥兀康鹊?。那我們就給他補(bǔ)充完全吧?。ㄟ@只是我想到的，我沒(méi)考慮到的你們也可以自己完善哈）

class RequestQueue {
    constructor(limit,delay) {
        this.limit = limit; // 最大并發(fā)請(qǐng)求數(shù)
        this.delay = delay; // 批次間隔時(shí)間（毫秒）
        this.queue = []; // 請(qǐng)求隊(duì)列
        this.running = 0; // 當(dāng)前正在運(yùn)行的請(qǐng)求數(shù)量
    }
    // 將請(qǐng)求添加到隊(duì)列中
    enqueue(request) {
        this.queue.push(request);
        this.run(); // 檢查是否可以運(yùn)行新的請(qǐng)求
    }
    // 檢查并運(yùn)行請(qǐng)求
    run() {
        while (this.running < this.limit && this.queue.length > 0) {
            const request = this.queue.shift();
            this.execute(request);
            this.running++;
        }
    }
    // 執(zhí)行請(qǐng)求
    execute(request) {
        request().finally(() => {
            this.running--;
            if (this.queue.length > 0) {
                setTimeout(() => {
                this.run();
                }, this.delay);
            }
        });
    }
}
// 模擬一個(gè)異步請(qǐng)求
function makeRequest(id) {
    return new Promise((resolve) => {
        console.log(`發(fā)起請(qǐng)求 ${id}`);
        setTimeout(() => {
            console.log(`請(qǐng)求 ${id} 完成`);
            resolve(id);
        }, 100);
    })
}
// 創(chuàng)建請(qǐng)求隊(duì)列并添加10,000個(gè)請(qǐng)求
const queue = new RequestQueue(5,1000);
for (let i = 1; i <= 20; i++) {
    queue.enqueue(async () => await makeRequest(i));
};

補(bǔ)充完整隊(duì)列

我們?cè)诒O(jiān)聽(tīng)隊(duì)列是否完成的時(shí)候注意一個(gè)事，就是Promise在返回的時(shí)候一定要在成功的時(shí)候才返回。至于原因，你們可以自己去嘗試哈。

class RequestQueue {
    timer = null; // 定時(shí)器
    constructor(limit, delay) {
        this.limit = limit; // 最大并發(fā)請(qǐng)求數(shù)
        this.delay = delay; // 批次間隔時(shí)間（毫秒）
        this.queue = []; // 請(qǐng)求隊(duì)列
        this.running = 0; // 當(dāng)前正在運(yùn)行的請(qǐng)求數(shù)量
    }
    // 將請(qǐng)求添加到隊(duì)列中
    enqueue(request) {
        this.queue.push(request);
        this.run(); // 檢查是否可以運(yùn)行新的請(qǐng)求
    }
    // 檢查并運(yùn)行請(qǐng)求
    run() {
        while (this.running < this.limit && this.queue.length > 0) {
            const request = this.queue.shift();
            this.execute(request);
            this.running++;
        }
    }
    // 執(zhí)行請(qǐng)求
    execute(request) {
        request().finally(() => {
            this.running--;
            if (this.queue.length > 0) {
                setTimeout(() => {
                    this.run();
                }, this.delay);
            }
        });
    }
    // 監(jiān)聽(tīng)隊(duì)列是否完成
    isQueueEmpty() {
        return new Promise((resolve, reject) => {
            this.timer = setInterval(() => {
                if (this.queue.length === 0 && this.running === 0) {
                    clearInterval(this.timer);
                    this.timer = null;
                    resolve(true);
                }
            }, 1000);
        })
    }
}
// 模擬一個(gè)異步請(qǐng)求
function makeRequest(id) {
    return new Promise((resolve) => {
        console.log(`發(fā)起請(qǐng)求 ${id}`);
        setTimeout(() => {
            console.log(`請(qǐng)求 ${id} 完成`);
            resolve(id);
        }, 100);
    })
}
// 創(chuàng)建請(qǐng)求隊(duì)列并添加10,000個(gè)請(qǐng)求
const queue = new RequestQueue(5, 1000);
for (let i = 1; i <= 20; i++) {
    queue.enqueue(async () => await makeRequest(i));
};
// 執(zhí)行完成返回ture
queue.isQueueEmpty().then(res=>{
    console.log(res);
})