()
| 28 | let maxConcurrent = 0; |
| 29 | |
| 30 | const makeTask = () => async () => { |
| 31 | concurrent++; |
| 32 | maxConcurrent = Math.max(maxConcurrent, concurrent); |
| 33 | await new Promise(resolve => setTimeout(resolve, 10)); |
| 34 | concurrent--; |
| 35 | }; |
| 36 | |
| 37 | queue.enqueue(makeTask()); |
| 38 | queue.enqueue(makeTask()); |