126 lines
3.0 KiB
JavaScript
126 lines
3.0 KiB
JavaScript
/*
|
||
* This file is part of the jquery plugin "asyncQueue".
|
||
*
|
||
* (c) Sebastien Roch <roch.sebastien@gmail.com>
|
||
* @author (parallel) Dmitry Farafonov
|
||
*
|
||
* For the full copyright and license information, please view the LICENSE
|
||
* file that was distributed with this source code.
|
||
*/
|
||
(function($){
|
||
$.AsyncQueue = function() {
|
||
var that = this,
|
||
queue = [],
|
||
completeFunc,
|
||
failureFunc,
|
||
paused = false,
|
||
lastCallbackData,
|
||
_run,
|
||
_complete,
|
||
inQueue = 0,
|
||
defaultTimeOut = 10;
|
||
|
||
_run = function() {
|
||
var f = queue.shift();
|
||
|
||
if (f) {
|
||
inQueue++;
|
||
setTimeout(function(){
|
||
f.fn.apply(that, [that]);
|
||
|
||
if (!f.isParallel)
|
||
if (paused === false) {
|
||
_run();
|
||
}
|
||
inQueue --;
|
||
if (inQueue == 0 && queue.length == 0)
|
||
_complete();
|
||
}, f.timeOut);
|
||
|
||
if (f.isParallel)
|
||
if (paused === false) {
|
||
_run();
|
||
}
|
||
}
|
||
};
|
||
|
||
_complete = function(){
|
||
if (completeFunc)
|
||
completeFunc.apply(that, [that]);
|
||
};
|
||
|
||
this.onComplete = function(func) {
|
||
completeFunc = func;
|
||
};
|
||
|
||
this.onFailure = function(func) {
|
||
failureFunc = func;
|
||
};
|
||
|
||
this.add = function(func) {
|
||
// TODO: add callback for queue[i] complete
|
||
|
||
var obj = arguments[0];
|
||
if (obj && Object.prototype.toString.call(obj) === "[object Array]") {
|
||
var fn = arguments[1];
|
||
var timeOut = (typeof(arguments[2]) != "undefined")? arguments[2] : defaultTimeOut;
|
||
if (typeof(fn) == "function") {
|
||
for(var i = 0; i < obj.length; i++) {
|
||
var f = function(objx){
|
||
queue.push({isParallel: true, fn: function(){fn.apply(that, [that, objx]);}, timeOut: timeOut});
|
||
}(obj[i])
|
||
}
|
||
}
|
||
} else {
|
||
var fn = arguments[0];
|
||
var timeOut = (typeof(arguments[1]) != "undefined")? arguments[2] : defaultTimeOut;
|
||
queue.push({isParallel: false, fn: func, timeOut: timeOut});
|
||
}
|
||
return this;
|
||
};
|
||
|
||
this.addParallel = function(func, timeOut) {
|
||
// TODO: add callback for queue[i] complete
|
||
|
||
queue.push({isParallel: true, fn: func, timeOut: timeOut});
|
||
return this;
|
||
};
|
||
|
||
this.storeData = function(dataObject) {
|
||
lastCallbackData = dataObject;
|
||
return this;
|
||
};
|
||
|
||
this.lastCallbackData = function () {
|
||
return lastCallbackData;
|
||
};
|
||
|
||
this.run = function() {
|
||
paused = false;
|
||
_run();
|
||
};
|
||
|
||
this.pause = function () {
|
||
paused = true;
|
||
return this;
|
||
};
|
||
|
||
this.failure = function() {
|
||
paused = true;
|
||
if (failureFunc) {
|
||
var args = [that];
|
||
for(i = 0; i < arguments.length; i++) {
|
||
args.push(arguments[i]);
|
||
}
|
||
failureFunc.apply(that, args);
|
||
}
|
||
};
|
||
|
||
this.size = function(){
|
||
return queue.length;
|
||
};
|
||
|
||
return this;
|
||
}
|
||
})(jQuery);
|