0

我在 Async 模块中使用 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');   
});

4

1 回答 1

1

如果我正确理解您的代码段，callback则永远不会调用您的函数：

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

这是一个问题。

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

因此，特别是由于 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)
})

编辑： 根据新的代码片段：

代码的第一部分看起来不错，直到 gm call 应该这样做：

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');   
  });
});
于 2014-10-02T10:46:31.540 回答