|
|
/* |
|
|
* 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);
|
|
|
|
