Javascript实现异步任务队列类

TaskQe.js

/* 
  @Author:thewei
  @website:http://www.99is.com
  @title: 异步事件任务队列类
*/
 
(function(){
 
	TaskQe = function(){
		this._arrayFn = [];   //事件集合
		this._callback = {};  //最终回调
        this._backdata = [];  // 返回数据集合
        this._isParallel = false;  // 是否并行，默认否
	};
 
	// 加入队列
	TaskQe.prototype.add = function(fn){
		this._arrayFn.push(fn);
		return this;
	};
 
	// 队列数目
	TaskQe.prototype.size = function(){
		return this._arrayFn.length;
	};
    
    // 获取返回数据集合
    TaskQe.prototype.getCallBack = function(){
        return this._backdata;
    }
 
	// 依次运行队列
	TaskQe.prototype.next = function(data){
 
		var fn = this.getNext();
        
        // 并行 or 串行
        (this._isParallel)?((fn)&&fn()):((fn)&&((data)?fn(data):fn()));
        
        // 集合返回数据
        (data)?this._backdata.push(data):this._backdata.push(false);
        
        // 返回总回调
        if(!this.size() && !fn) {
            if(typeof this._callback === "function") {
                (data)?this._callback(data):this._callback();
            }
        };
        
		return this;
	};
 
	// 队列执行
	TaskQe.prototype.getNext = function(){
		if(this.size()){
			return this._arrayFn.shift();
		}
		return false;
	}
 
	// 初始化，完成后执行,第一个参数是否并行，第二个参数返回
	TaskQe.prototype.run = function(){
        if(arguments.length === 1 ){
            this._callback = (typeof arguments[0] === "function")?arguments[0]:{};
            this._isParallel = (typeof arguments[0] === "boolean")?arguments[0]:false;
        }      
        if(arguments.length === 2 ){
            this._callback = (typeof arguments[1] === "function")?arguments[1]:{};
            this._isParallel = (typeof arguments[0] === "boolean")?arguments[0]:false;
        } 
        var firstFn = this.getNext();
		firstFn();
        
		return this;
	};
 
	return TaskQe;
})();


// 初始化任务类
var taskQe = new TaskQe();

var aa = function(){
	for(var i=1; i<4; i++){
		$.ajax({
			type:"get",
			url: "data/a"+i+".html?_="+new Date().getTime(),
			success: function(data){
				console.log(i) // 如何把值保存起来
				taskQe.next(data); // 通知执行下一个任务
			}
		});
	}
}

// 添加任务
taskQe.add(aa);
// 执行任务
taskQe.run(function(dd){
	console.log(dd)
});


/*
// 例子
function a1(lastData){
	if(lastData) console.log(lastData);
	$.ajax({
		type:"get",
		url: "data/a1.html?_="+new Date().getTime(),
		success: function(data){
			taskQe.next(data); // 通知执行下一个任务
		}
	});

}

function a2(lastData){
	if(lastData) console.log(lastData);
	$.ajax({
		type:"get",
		url: "data/a2.html?_="+new Date().getTime(),
		success: function(data){
			taskQe.next(data); // 通知执行下一个任务
		}
	});

}

function a3(lastData){
	if(lastData) console.log(lastData);
	$.ajax({
		type:"get",
		url: "data/a3.html?_="+new Date().getTime(),
		success: function(data){
			taskQe.next(data); // 通知执行下一个任务
		}
	});

}
*/