Whats cách thông minh nhất/sạch nhất để lặp lại async qua mảng (hoặc objs) là gì?

Question

Đó là cách tôi thực hiện:

function processArray(array, index, callback) { 
    processItem(array[index], function(){ 
     if(++index === array.length) { 
      callback(); 
      return; 
     } 
     processArray(array, index, callback); 
    }); 
}; 

function processItem(item, callback) { 
    // do some ajax (browser) or request (node) stuff here 

    // when done 
    callback(); 
} 

var arr = ["url1", "url2", "url3"]; 

processArray(arr, 0, function(){ 
    console.log("done"); 
}); 

Có tốt không? Làm thế nào để tránh những mã spaghetti'ish?

Answer 1

Thanh toán thư viện async, nó được tạo cho luồng điều khiển (công cụ không đồng bộ) và nó có rất nhiều phương pháp cho mảng công cụ: mỗi bộ lọc, bản đồ. Kiểm tra tài liệu trên github. Đây là những gì bạn có thể cần:

mỗi (arr, iterator, callback)

Áp dụng một chức năng lặp cho mỗi mục trong một mảng, song song. Trình lặp được gọi với một mục từ danh sách và một cuộc gọi lại khi nó đã kết thúc. Nếu trình vòng lặp chuyển một lỗi tới cuộc gọi lại này, cuộc gọi lại chính cho hàm each ngay lập tức được gọi với lỗi.

eachSeries (arr, iterator, callback)

Giống như each chỉ iterator được áp dụng cho từng hạng mục trong mảng trong loạt. Trình lặp tiếp theo chỉ được gọi khi trình xử lý hiện tại đã hoàn tất quá trình xử lý. Điều này có nghĩa là các hàm lặp sẽ hoàn thành theo thứ tự.

Answer 2

Như một cách chính xác chỉ ra, bạn phải sử dụng setTimeout, ví dụ:

each_async = function(ary, fn) { 
    var i = 0; 
    -function() { 
     fn(ary[i]); 
     if (++i < ary.length) 
      setTimeout(arguments.callee, 0) 
    }() 
} 


each_async([1,2,3,4], function(p) { console.log(p) }) 

Answer 3

Như đã chỉ trong một số câu trả lời người ta có thể sử dụng "async" thư viện. Nhưng đôi khi bạn không muốn giới thiệu sự phụ thuộc mới vào mã của bạn. Và dưới đây là một cách khác như thế nào bạn có thể lặp lại và chờ đợi để hoàn thành một số chức năng không đồng bộ.

var items = ["one", "two", "three"]; 

// This is your async function, which may perform call to your database or 
// whatever... 
function someAsyncFunc(arg, cb) { 
    setTimeout(function() { 
     cb(arg.toUpperCase()); 
    }, 3000); 
} 

// cb will be called when each item from arr has been processed and all 
// results are available. 
function eachAsync(arr, func, cb) { 
    var doneCounter = 0, 
     results = []; 
    arr.forEach(function (item) { 
     func(item, function (res) { 
      doneCounter += 1; 
      results.push(res); 
      if (doneCounter === arr.length) { 
       cb(results); 
      } 
     }); 
    }); 
} 

eachAsync(items, someAsyncFunc, console.log); 

Bây giờ, chạy node iterasync.js sẽ chờ khoảng ba giây và sau đó in [ 'ONE', 'TWO', 'THREE' ]. Đây là một ví dụ đơn giản, nhưng nó có thể được mở rộng để xử lý nhiều tình huống.

Answer 4

Cách dễ nhất để xử lý lặp lại không đồng bộ của mảng (hoặc bất kỳ lần lặp nào khác) là với toán tử chờ (chỉ trong các hàm không đồng bộ) và cho vòng lặp.

(async function() { 
 
for(let value of [ 0, 1 ]) { 
 
    value += await(Promise.resolve(1)) 
 
    console.log(value) 
 
} 
 
})()

Bạn có thể sử dụng một thư viện để chuyển đổi bất kỳ chức năng bạn có thể cần mà chấp nhận callback để trở lại hứa hẹn.