節點js +異步並行+函數調用方法不起作用

Question

我在不同的地方有功能（這是常用的功能，它會使用很多地方） 所以我試着用異步並行調用函數但是不工作 I附我的代碼如下：L

var userId = 33; 

async.parallel({ 
     video(userId, callback) { 
      callback(null, callback); 
     }, 
     video1(userId, callback) { 
      callback(null, callback); 
     } 
    }, function(err, results) { 
     console.log(results); 
    }); 



    function video (userId, callback) { 
     client.query("select youtube_id,title,id,thumbnail,search_item from resource order by random() limit 1 ", function(err, video) { 
      callback(err, video); 
     }); 

    } 

    function video1(userId, callback) { 
      client.query("select youtube_id,title,id,thumbnail,search_item from resource1 order by random() limit 1 ", function(err, video1) { 
       callback(err, video1); 
      }); 

     } 

Answer 1

的{fnName()}語法是一個函數聲明你想用一個函數調用......其實你也可以只使用async.parallel({video, video1}, (err, results) => console.log(results)來達到同樣的效果......除非你。還需要通過userId。所以你實際打算的是這個函數調用而不是它聲明：

async.parallel([ 
    callback => video(userId, callback), 
]); 

Answer 2

你需要的功能的引用傳遞給async.parallel()，你需要傳遞一個數組，而不是一個對象。你想要的代碼有這樣的形式：

async.parallel([fn1, fn2], finalCallback); 

您要使用的語法的具體例子見async.parallel() doc here。

凡fn1，fn2和finalCallback都是函數引用可以由async.parallel()基礎設施，而不是你自己叫什麼叫。

你的代碼改成這樣：

async.parallel([ 
    function(callback) { 
     client.query("select youtube_id,title,id,thumbnail,search_item from resource order by random() limit 1 ", function(err, video) { 
      callback(err, video); 
     }), 
    }, 
    function(callback) { 
     client.query("select youtube_id,title,id,thumbnail,search_item from resource order by random() limit 1 ", function(err, video1) { 
      callback(err, video1); 
     }); 
    } 
], function(err, results) { 
     console.log(results); 
}); 

想必，你的兩個數據庫查詢應該是不同的某種方式（你的代碼表明它們是相同的）。

如果你的函數已經定義在某處，那麼你可以傳遞一個匿名函數引用來調用它們。如果您的功能沒有async.parallel()需要的完全相同的調用約定，則需要執行此操作。你可以這樣做：

async.parallel([function(callback) { 
      video(userId, callback); 
     }, function(callback) { 
      video1(userId, callback); 
     }], function(err, results) { 
     console.log(results); 
});