// 生成用于測試的任務集合
const tasks = new Array(10).fill(0).map((v, i) => {
    return function task() {
        return new Promise((resolve) => {
            setTimeout(() => {
                resolve(i + 1)
            }, i * 1000);
        })
    }
})

// 并發(fā)控制函數(shù)
function concurrencyControl(tasks, limit, callback) {
    const queue = tasks.slice()  // 當前執(zhí)行的任務隊列
    let count = 0 // 已完成的任務數(shù)量
    const runTask = () => {
        while (limit) {
            limit--
            if (queue.length) {
                const task = queue.shift() // 取出當前隊頭任務
                task().then(() => {
                    limit++
                    count++
                    if (count === tasks.length) { // 最后一個任務
                        callback() // 執(zhí)行回調(diào)函數(shù)
                    }else{
                        runTask() // 繼續(xù)執(zhí)行下一個任務
                    }
                })
            }
        }
    }
    return runTask
}
// 測試代碼
const sendRequest = concurrencyControl(tasks, 3, (taskId) => {
    console.log(`task ${taskId} finish！`)
})
sendRequest()

class ConcurrencyControl {
    constructor(tasks, limit, callback) {
        this.queue = tasks.slice() // 當前執(zhí)行的任務隊列
        this.tasks = tasks // 原始任務集合
        this.count = 0 // 已完成的任務數(shù)量
        this.limit = limit
        this.callback = callback
    }
    runTask() {
        while (this.limit) {
            this.limit--
            if (this.queue.length) {
                const task = this.queue.shift() // 取出隊頭任務
                task().finally(() => {
                    this.limit++
                    this.count++
                    if (this.count === this.tasks.length) { // 最后一個任務
                        this.callback() // 執(zhí)行回調(diào)函數(shù)
                    } else {
                        this.runTask() // 繼續(xù)執(zhí)行下一個任務
                    }
                })
            }
        }
    }
    addTask(task) {
        // 同步添加任務
        this.queue.push(task)
        this.tasks.push(task)
        // 當直接調(diào)用 addTask 也可直接執(zhí)行
        this.runTask()
    }
}
// 測試代碼
const Control = new ConcurrencyControl(tasks, 3, () => {
    console.log(`task all finish！`)
})
// 執(zhí)行隊列任務
Control.runTask()
// 添加新任務
Control.addTask(function task() {
    return new Promise((resolve) => {
        setTimeout(() => {
            console.log(`task ${Control.tasks.length} finish！`)
            resolve(Control.tasks.length)
        }, Control.tasks.length * 200);
    })
})

class ConcurrencyControl {
    constructor(tasks, limit, callback) {
        this.tasks = tasks.slice() // 淺拷貝，避免修改原數(shù)據(jù)
        this.queue = new Set() // 任務隊列
        this.limit = limit // 最大并發(fā)數(shù)
        this.callback = callback // 回調(diào)
    }
    runTask() {
        // 邊界判斷
        if(this.tasks.length == 0) return
        // 當任務隊列有剩余，繼續(xù)添加任務 
        while (this.queue.size < this.limit) {
            const task = this.tasks.shift() // 取出隊頭任務
            this.queue.add(task) // 往隊列中添加當前執(zhí)行的任務
            task()
                .finally(() => {
                    this.queue.delete(task) // 當前任務執(zhí)行完畢，從隊列中刪除改任務
                    if (this.queue.size == 0) {
                        this.callback() // 執(zhí)行回調(diào)函數(shù)
                    } else {
                        this.runTask() // 繼續(xù)執(zhí)行下一個任務
                    }
                })
        }
    }
    addTask(task) {
        // 同步添加任務
        this.tasks.push(task)
        // 當直接調(diào)用 addTask 也可直接執(zhí)行
        this.runTask()
    }
}
// 測試代碼
const Control = new ConcurrencyControl(tasks, 3, () => {
    console.log(`task all finish！`)
})
Control.runTask() // 執(zhí)行隊列任務
Control.addTask(function task() { // 添加新任務
    return new Promise((resolve) => {
        setTimeout(() => {
            console.log(`task 9999 finish！`)
            resolve(999)
        }, 100);
    })
})