nolotus / asyncqueue Goto Github PK

串行执行任务
    let asyncQueue:AsyncQueue = new AsyncQueue();

    // 最简洁的调用，push一个延时50毫秒的回调任务，每一个异步任务的next必须调用。
    asyncQueue.push( (next:Function)=>{
        // TODO
        setTimeout(next, 50);
    })

    // 传入一个params参数对象
    asyncQueue.push( (next:Function,params:any,args:any)=>{
        let _delay = params["delay"];
        console.log("params",params)
        setTimeout( ()=>{
            next( 222 );
        } , _delay );
    }, {delay:100} );

    // 通过args获取上个异步任务传递过来的值。
    asyncQueue.push( (next:Function,params:any,args:any)=>{
        let _delay = args;
        setTimeout( ()=>{
            next( "complete" );
        } , _delay );
    });
// 同时处理多个异步任务，全部完成后，跳转下一步
asyncQueue.pushMulti({name:"abc"}, (next:Function,params:any,args:any)=>{
        let _delay = args;
        setTimeout( ()=>{
            next( "completeA" );
        } ,  2 );
    }, (next:Function,params:any,args:any)=>{
        let _delay = args;
        setTimeout( ()=>{
            next( "completeB" );
        } , 4 );
    } );
    
// 同时push多个任务，可以设定第三个参数，即任务执行优先级，数值越大越优先执行
asyncQueue.push( (next:Function)=>{
        // TODO
        setTimeout(next, 50);
    },null,1)
asyncQueue.push( (next:Function)=>{
        // TODO
        setTimeout(next, 50);
    },null,2)
asyncQueue.push( (next:Function)=>{
        // TODO
        setTimeout(next, 50);
    },null,3)

    // 延时333毫秒然后执行下一步
    asyncQueue.yieldTime(333);
    
    // 设置完成时的回调函数
    asyncQueue.complete = (args)=>{
        console.log(args);
    }
    
    // 运行, 必须执行play方法才会运行
    asyncQueue.play();

	asyncQueue.enable = false;

	asyncQueue.enable = false;

           /**
     * 有5个任务需要执行，由于系统限制，同时执行的任务不能超过3个
     */
    let tasks = [100, 200, 300, 450, 600]; // 任务数组耗时毫秒数
    let pQueue = new ParallelQueue<number>(2);
    pQueue.play(tasks, (taskIndex: number, taskValue: number, workerIndex, next) => {
        console.log(`执行任务索引${taskIndex} 任务值${taskValue}  Worker: ${workerIndex}`)
        setTimeout(next, taskValue);
    });
    pQueue.complete = () => {
        console.log(" 总耗时 ", (Date.now() - t) )
    }