Javascript - đang đợi một số cuộc gọi lại không đồng bộ trở lại?

Question

Cách tốt nhất/thư viện để xử lý nhiều cuộc gọi lại không đồng bộ là gì? Ngay bây giờ, tôi có một cái gì đó như thế này:

_.each(stuff, function(thing){ 
    async(thing, callback); 
}); 

tôi cần phải thực hiện một số mã sau khi gọi lại đã bị sa thải cho mỗi phần tử trong stuff.

Cách sạch nhất để thực hiện việc này là gì? Tôi đang mở để sử dụng thư viện.

Answer 1

Có một thư viện tuyệt vời được gọi là Async.js giúp giải quyết các vấn đề như thế này với nhiều người trợ giúp điều khiển luồng không đồng bộ &. Nó cung cấp một số hàm forEach có thể giúp bạn chạy callbacks cho mọi mục trong một mảng/đối tượng.

Check-out: https://github.com/caolan/async#forEach

// will print 1,2,3,4,5,6,7,all done 

var arr = [1,2,3,4,5,6,7]; 

function doSomething(item, done) { 
    setTimeout(function() { 
    console.log(item); 
    done(); // call this when you're done with whatever you're doing 
    }, 50); 
} 

async.forEach(arr, doSomething, function(err) { 
    console.log("all done"); 
}); 

Answer 2

Có bộ đếm, nói async_count. Tăng nó mỗi lần bạn bắt đầu một yêu cầu (bên trong vòng lặp của bạn) và có callback giảm nó bằng một và kiểm tra nếu không đạt được - nếu như vậy, tất cả các callbacks đã trở lại. EDIT: Mặc dù, nếu tôi là người viết bài này, tôi sẽ xâu chuỗi các yêu cầu thay vì chạy chúng song song - nói cách khác, tôi có một hàng đợi các yêu cầu và có cuộc gọi lại kiểm tra hàng đợi cho yêu cầu tiếp theo chế tạo.

Answer 3

Kể từ khi bạn đã sử dụng gạch dưới bạn có thể nhìn vào _.after. Nó thực hiện chính xác những gì bạn đang yêu cầu. Từ các tài liệu:

sau       _.after(count, function)

Tạo một phiên bản của các chức năng đó sẽ chỉ được chạy sau khi lần đầu tiên được gọi lần đếm. Hữu ích cho việc nhóm các câu trả lời không đồng bộ, nơi bạn muốn chắc chắn rằng tất cả các cuộc gọi không đồng bộ đã kết thúc, trước khi tiếp tục.

Answer 4

Xem phản ứng của tôi đến một câu hỏi tương tự:

Coordinating parallel execution in node.js

chức năng My fork() duy trì truy cập nội bộ và tự động.

Answer 5

Tôi khuyên bạn nên https://github.com/caolan/async cho việc này. Bạn có thể sử dụng async.parallel để thực hiện việc này.

function stuffDoer(thing) { 
    return function (callback) { 
     //Do stuff here with thing 
     callback(null, thing); 
    } 
} 

var work = _.map(stuff, stuffDoer) 
async.parallel(work, function (error, results) { 
    //error will be defined if anything passed an error to the callback 
    //results will be an unordered array of whatever return value if any 
    //the worker functions passed to the callback 
} 

Answer 6

async.parallel()/async.series phải phù hợp với yêu cầu của bạn. Bạn có thể cung cấp với một cuộc gọi lại cuối cùng được thực thi khi tất cả các cuộc gọi REST thành công.

async.parallel([ 
    function(){ ... }, 
    function(){ ... } 
], callback); 
async.series([ 
    function(){ ... }, 
    function(){ ... } 
], callback);