bf

class LimitPromise{
    constructor(max){
        this._max = max || 6 // 最大执行数量
        this._count = 0 // 当前执行的数量
        this._taskQueue = [] // 队列   
        this.instance = null // 实例 单例模式
    }
    run(caller){
        return new Promise((resolve, reject)=>{
            const task = this._createTask(caller, resolve, reject)
            // 当前执行的数量 > 最大执行数量，就加入队列排队；否则直接执行
            if(this._count >= this._max){
                this._taskQueue.push(task)
            }else {
                task()
            }
        })   
    }
    _createTask(caller, resolve, reject){
        return ()=> {
            caller().then(res =>{
                resolve(res)
            }).catch(err => {
                reject(err)
                //调用finally的promise实例,无论成功和失败都会进入finally中执行
            }).finally(()=>{
                // 执行完成
                this._count--
                if(this._taskQueue.length > 0){
                    // 取出队列中的首位执行
                    const task= this._taskQueue.shift()
                    task()
                }
            })
            this._count++
        }
    }
    static getInstance(max){
        if(!this.instance){
            this.instance = new LimitPromise(max)
        }
        return this.instance
    }
}

// 构获取实例
const limitPromise = LimitPromise.getInstance(3)
const asyncTask = (params) => {
   return new Promise((resolve, reject)=>{
        setTimeout(() => {
            if (params % 2 == 0) {
                resolve({
                    tag:'成功了', params
                })
            } else {
                reject({
                    tag:'失败了', params
                })
            }
        }, 1000)
    })
}

for(let i=0; i<= 100; i++){
    limitPromise.run(() => asyncTask(i)).then(
        result => {
            console.log('result', result)
        },
        error => {
            console.log('error', error)
        }
    )
}