nodejs中的异步和并行函数

Question

我在异步模块中使用 parallel() 函数获取并发出问题...

数组images 为空...

var asyncTasks = [];

switch(type){
  case 'instafilm':

    var newFileName;
    var images = [];

    selectedPhotos.forEach(function(id){
      newFileName = pathDir + '/' + id + '.jpg';
      asyncTasks.push(function(callback){
        self.api.media(id, function(err, media, remaining, limit) {
          images.push(media.images.thumbnail.url);
        });
      });
    });

    asyncTasks.push( function(callback){
      console.log(images); // empty
    });


    break;
}

console.log(images); // empty

编辑#1：

var asyncTasks = [];

var newFileName;
var images = [];

selectedPhotos.forEach(function(id){
  newFileName = pathDir + '/' + id + '.jpg';
  asyncTasks.push(function(callback){
    self.api.media(id, function(err, media, remaining, limit) {
      images.push(media.images.thumbnail.url);
      callback(null);
    });
  });
});

asyncTasks.push( function(callback){
  console.log(images); // before creating .zip I need to write files using images[]
  gm()
  .in('-page', '+0+0')
  .in('./public/images/instafilm.jpg')
  .in('-page', '+10+10')
  .in(images[0])
  .in('-page', '+10+30')
  .in(images[1])
  .in('-page', '+10+60')
  .in(images[2])
  .in('-page', '+10+90')
  .in(images[3])
  .mosaic()
  .minify()
  .write(newFileName, function (err) {
    if (!err) console.log('done');
    if (err) console.log(err);
    callback();
  });
});



async.parallel(asyncTasks, function(){
    // here I write a .zip file
    var admZip = new AdmZip();
    var pathDir = './public/uploads/'+reference;
    admZip.addLocalFolder(pathDir);
    var willSendthis = admZip.toBuffer();
    admZip.writeZip('./public/uploads/'+reference+'.zip');   
});

Answer 1

如果我理解你的 sn-p 正确，你的 callback 函数永远不会被调用：

self.api.media(id, function(err, media, remaining, limit) {
  images.push(media.images.thumbnail.url);
});

这是个问题。

我能想到的另一个问题是您在执行此 sn-p 之后调用 console.log(images)（因此尚未执行异步代码）并作为并行调用的一部分。但是正如它的名字所暗示的那样（它是docconfirm）并行运行你的任务“并行”（尽可能多的节点允许它）。

因此，特别是由于 console.log() 是同步的，因此您的 media([...]) 调用将没有时间在控制台调用之前完成。

如果我猜对了，那么你需要像这样添加一个回调：

function(callback){
  self.api.media(id, function(err, media, remaining, limit) {
    images.push(media.images.thumbnail.url);
    callback(null);
  });
}

并检查图像内容之后你的异步代码完成像：

parallel(asyncTasks,function(){
  console.log(images)
})

编辑： 根据新代码 sn -p ：

代码的第一部分看起来不错，直到 gm 调用应该这样完成：

async.parallel(asyncTasks, function(){
  gm()
  .in('-page', '+0+0')
  .in('./public/images/instafilm.jpg')
  .in('-page', '+10+10')
  .in(images[0])
  .in('-page', '+10+30')
  .in(images[1])
  .in('-page', '+10+60')
  .in(images[2])
  .in('-page', '+10+90')
  .in(images[3])
  .mosaic()
  .minify()
  .write(newFileName, function (err) {
    if (!err) console.log('done');
    if (err) console.log(err);
    // here I write a .zip file
    var admZip = new AdmZip();
    var pathDir = './public/uploads/'+reference;
    admZip.addLocalFolder(pathDir);
    var willSendthis = admZip.toBuffer();
    admZip.writeZip('./public/uploads/'+reference+'.zip');   
  });
});