💻 오늘의 코드 팁 — 🛠️ 처음부터 만드는 Promise Pool — p-limit 스타일 동시성 제어 20줄 구현

문제

API 1,000개를 동시에 호출하면?
```typescript
// ❌ 서버 과부하, rate limit, 메모리 폭발
const results = await Promise.all(
urls.map(url => fetch(url))
);
```
1,000개가 동시에 출발한다. 서버는 429를 뿜고, 브라우저는 멈춘다.
필요한 건 "한 번에 최대 N개만" 실행하는 동시성 풀이다.
---

코드 — 20줄 Promise Pool

```typescript
class Pool {
private queue: (() => void)[] = [];
private running = 0;
constructor(private concurrency: number) {}
async add(fn: () => Promise): Promise {
if (this.running >= this.concurrency) {
await new Promise(r => this.queue.push(r));
}
this.running++;
try {
return await fn();
} finally {
this.running--;
this.queue.shift()?.();
}
}
async map(items: T[], fn: (item: T) => Promise): Promise {
return Promise.all(items.map(item => this.add(() => fn(item))));
}
}
```
---

사용 예제

```typescript
const pool = new Pool(5); // 동시 최대 5개
// 개별 추가
const result = await pool.add(() => fetch('/api/data'));
// 배열 일괄 처리 — 1,000개지만 5개씩만 실행
const urls = Array.from({ length: 1000 }, (_, i) => `/api/item/${i}`);
const results = await pool.map(urls, async (url) => {
const res = await fetch(url);
return res.json();
});
console.log(results); // 1,000개 결과, 5개씩 순차 처리됨
```
---

작동 원리

```
concurrency = 3일 때:
시간 → ████ task1 완료
██████████ task2
███████ task3
████ task4 (task1 끝나자 시작)
██ task5 (task3 끝나자 시작)
```
핵심은 세마포어(Semaphore) 패턴이다:
| 단계 | 코드 | 역할 |
|------|------|------|
| 대기 | `await new Promise(r => queue.push(r))` | 슬롯이 없으면 큐에서 잠든다 |
| 진입 | `running++` | 슬롯 획득 |
| 실행 | `return await fn()` | 실제 작업 수행 |
| 반환 | `finally { running--; queue.shift()?.() }` | 슬롯 반환 + 다음 작업 깨움 |
`try/finally`가 핵심이다 — 에러가 나도 슬롯은 반드시 반환된다.
---

실전 활용

파일 업로드 (3개씩):
```typescript
const upload = new Pool(3);
await upload.map(files, async (file) => {
const form = new FormData();
form.append('file', file);
return fetch('/upload', { method: 'POST', body: form });
});
```
DB 쿼리 (커넥션 풀 제한):
```typescript
const db = new Pool(10);
const users = await db.map(userIds, id =>
prisma.user.findUnique({ where: { id } })
);
```
웹 크롤링 (rate limit 준수):
```typescript
const crawler = new Pool(2); // 예의 바르게 2개씩
const pages = await crawler.map(urls, async (url) => {
const html = await fetch(url).then(r => r.text());
await delay(500); // 추가 딜레이
return parse(html);
});
```
---

라이브러리와 비교

| 라이브러리 | 주간 다운로드 | 핵심 기능 |
|-----------|-------------|----------|
| [p-limit](https://github.com/sindresorhus/p-limit) | 1억+ | 동시성 제한 (우리가 만든 것) |
| [p-queue](https://github.com/sindresorhus/p-queue) | 500만+ | 우선순위 큐 + 동시성 |
| [bottleneck](https://github.com/SGrondin/bottleneck) | 300만+ | Rate limiting + 클러스터 |
20줄 Pool이 p-limit의 핵심을 그대로 담고 있다. 우선순위, 타임아웃, 재시도가 필요하면 라이브러리를 쓰자.
---

한 줄 요약

> `Promise.all`은 "전부 동시에", `Pool`은 "N개씩 동시에" — `queue`에 잠들고, `finally`에서 깨운다.
---
📚 참고 문서:

[MDN — Promise.all()](https://developer.mozilla.org/en-US/docs/Web/JavaScript/Reference/Global_Objects/Promise/all)

[MDN — Concurrency model and Event Loop](https://developer.mozilla.org/en-US/docs/Web/JavaScript/Event_loop)

[p-limit GitHub](https://github.com/sindresorhus/p-limit) — 이 패턴의 원본 라이브러리