<pre class="shiki github-dark shaku"><code>class AsyncTaskQueue { limit: number; count: number = 0; queueList: (() =&gt; Promise&lt;any&gt;)[] = []; constructor(concurrency: number) { // Initialize the queue with the specified concurrency limit this.limit = concurrency; this.count = 0; this.queueList = []; } queue(task: () =&gt; Promise&lt;any&gt;) { // Add an async task to the queue const runner = () =&gt; this.runTask(task); if ( this.count &lt; this.limit ) { runner(); } else { this.queueList.push(runner); } } private async runTask(task: () =&gt; Promise&lt;any&gt;) { this.count++; try { await task(); } catch (e) { console.log("Failed to run task: "+e) } finally { this.count--; if (this.queueList.length &gt; 0 ) { const nextTask = this.queueList.shift(); if (nextTask) { nextTask(); } } } }}const queue = new AsyncTaskQueue(2); // Allow up to 2 tasks to run concurrently// Example async tasksconst task1 = () =&gt; new Promise((resolve) =&gt; setTimeout(() =&gt; resolve("Task 1 done"), 1000));const task2 = () =&gt; new Promise((resolve, reject) =&gt; setTimeout(() =&gt; reject("Task 2 failed"), 500));const task3 = () =&gt; new Promise((resolve) =&gt; setTimeout(() =&gt; resolve("Task 3 done"), 200));// Queue tasksqueue.queue(task1); // Starts immediatelyqueue.queue(task2); // Starts immediately (concurrency = 2)queue.queue(task3); // Waits until one of the first two tasks completes</code></pre>

FIFO Async Task Queue with Dynamic Concurrency Control

Design and implement an AsyncTaskQueue class that manages the execution of asynchronous tasks with a specified maximum concurrency limit. The queue sh…