我使用mbostock / queue来排队一些异步操作。不仅要进行速率限制(UI生成的事件很少,后端可以缓慢地处理该事件),而且还要确保依次处理它们。我用它像
function request(d, cb) { //some async oper add.then(function(){ cb(null, "finished ") }) } var addQ = queue(1); addQ.defer(request) //called by few req at higher rates generated by UI
我已经使用angular.js $ q进行异步操作了。所以,我必须使用mbostock/queue,还是可以建立一个队列$q(这本来就是https://github.com/kriskowal/q)
mbostock/queue
$q
谢谢。
是的,您 可以 使用Angular的$ q建立链式队列!这是一个示例,向您展示如何使用递归创建任何长度的队列。每个帖子都相继发生(一个接一个)。在第一篇文章完成之前,第二篇文章将不会开始。
这在写入数据库时可能会有所帮助。如果数据库在后端没有自己的队列,并且您同时进行多次写入,则可能会发现并非所有数据都已保存!
我添加了一个Plunkr示例来演示此代码的实际作用。
$scope.setData = function (data) { // This array will hold the n-length queue var promiseStack = []; // Create a new promise (don't fire it yet) function newPromise (key, data) { return function () { var deferred = $q.defer(); var postData = {}; postData[key] = data; // Post the the data ($http returns a promise) $http.post($scope.postPath, postData) .then(function (response) { // When the $http promise resolves, we also // resolve the queued promise that contains it deferred.resolve(response); }, function (reason) { deferred.reject(reason); }); return deferred.promise; }; } // Loop through data creating our queue of promises for (var key in data) { promiseStack.push(newPromise(key, data[key])); } // Fire the first promise in the queue var fire = function () { // If the queue has remaining items... return promiseStack.length && // Remove the first promise from the array // and execute it promiseStack.shift()() // When that promise resolves, fire the next // promise in our queue .then(function () { return fire(); }); }; // Begin the queue return fire(); };
您可以使用一个简单的函数开始队列。为了进行演示,我将一个充满键的对象传递给一个函数,该函数会将这些键拆分为各个帖子,然后将其发布到Henry的HTTP Post Dumping Server中。(感谢亨利!)
$scope.beginQueue = function () { $scope.setData({ a: 0, b: 1, /* ... all the other letters of the alphabet ... */ y: 24, z: 25 }).then(function () { console.log('Everything was saved!'); }).catch(function (reason) { console.warn(reason); }); };
如果您想尝试此代码,请参见以下指向Plunkr示例的链接。