(url, callback)
| 2 | |
| 3 | var concurrencyCount = 0; |
| 4 | var fetchUrl = function (url, callback) { |
| 5 | var delay = parseInt((Math.random() * 10000000) % 2000, 10); |
| 6 | concurrencyCount++; |
| 7 | console.log('现在的并发数是', concurrencyCount, ',正在抓取的是', url, ',耗时' + delay + '毫秒'); |
| 8 | setTimeout(function () { |
| 9 | concurrencyCount--; |
| 10 | callback(null, url + ' html content'); |
| 11 | }, delay); |
| 12 | }; |
| 13 | |
| 14 | var urls = []; |
| 15 | for(var i = 0; i < 30; i++) { |