💻 Dev

처음부터 만드는 AsyncPool — 동시 요청 개수를 제한하는 26줄 구현

# 동시성 제어가 필요한 이유
100개의 API 요청을 동시에 날리면? 서버가 거절하거나 레이트 제한(429)을 받습니다. 동시 작업 개수를 제한하면서 모두 완료를 기다려야 할 때 AsyncPool을 씁니다.

핵심 아이디어


큐에서 아이템을 꺼내고, 정해진 개수만큼만 동시 실행. 하나가 끝나면 다음 것 시작.
```typescript
async function asyncPool(
items: T[],
concurrency: number,
fn: (item: T) => Promise
): Promise {
const results = new Array(items.length);
const queue = items.map((item, idx) => ({ item, idx }));
const executing: Promise[] = [];
async function worker() {
while (queue.length > 0) {
const { item, idx } = queue.shift()!;
results[idx] = await fn(item);
}
}
for (let i = 0; i < Math.min(concurrency, items.length); i++) {
executing.push(worker());
}
await Promise.all(executing);
return results;
}
```

실전 예제


```typescript
const urls = ['api.com/1', 'api.com/2', 'api.com/3'];
const results = await asyncPool(urls, 2, async (url) => {
const res = await fetch(url);
return res.json();
});
// 최대 2개씩만 동시 요청 → 완료 순서대로 results에 저장
```

주요 포인트


  • queue.shift(): 아이템을 꺼내며 처리

  • new Array(length): 원래 순서 유지

  • worker 함수: 여러 개가 동시에 실행되며 큐 소비

  • 더 자세히: [Node.js Worker Threads](https://nodejs.org/api/worker_threads.html)
    💬 0
    👁 0 views

    Comments (0)

    💬

    No comments yet.

    Be the first to comment!