<pre class="shiki github-dark shaku"><code>class AsyncTaskQueue { capacity: number; running: number; arr: Array&lt; ()=&gt; Promise&lt;void&gt; &gt;; constructor(concurrency: number) { this.capacity = concurrency; this.running = 0; this.arr = []; } queue(task: () =&gt; Promise&lt;void&gt;) { this.arr.push(task); this.runTask() } runTask(){ if(this.running &lt; this.capacity){ const task: (() =&gt; Promise&lt;any&gt;) = this.arr.shift()!; this.running++; task() .then(() =&gt; { this.running--; if(this.running &lt; this.capacity){ this.runTask() } }) .catch((err) =&gt; { this.running--; }) } }}</code></pre>

created a separate function called runTask to handle concurrency

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