排队承诺

Question

我使用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）

谢谢。

Answer 1

基本$ 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示例的链接。