💻 Dev

🛠️ 처음부터 만드는 Promise Queue — 동시 실행 개수를 제한하기

API 100개를 동시에 호출하면? 서버가 거부하거나 브라우저가 멈춥니다. Promise Queue는 동시에 실행되는 비동기 작업 수를 제한하는 패턴입니다.

핵심 아이디어


대기열(queue)에 작업을 넣고, 동시 실행 슬롯이 빌 때마다 다음 작업을 꺼내 실행합니다.

구현


```typescript
function createQueue(concurrency: number) {
const queue: (() => Promise)[] = [];
let running = 0;
function next() {
while (running < concurrency && queue.length > 0) {
const task = queue.shift()!;
running++;
task().finally(() => {
running--;
next();
});
}
}
return function add(fn: () => Promise): Promise {
return new Promise((resolve, reject) => {
queue.push(() => fn().then(resolve, reject));
next();
});
};
}
```

사용 예시


```typescript
const enqueue = createQueue(3); // 최대 3개 동시 실행
const urls = Array.from({ length: 20 }, (_, i) => `https://api.example.com/item/${i}`);
const results = await Promise.all(
urls.map(url => enqueue(() => fetch(url).then(r => r.json())))
);
console.log(results); // 20개 결과, 3개씩 순차 실행됨
```

왜 유용한가?


| 상황 | concurrency 값 |
|---|---|
| 외부 API rate limit | 2~5 |
| 파일 동시 읽기 | 10~50 |
| DB 커넥션 풀 | 풀 크기에 맞춤 |

동작 원리


1. `add()` 호출 → 작업을 queue에 추가하고 `next()` 실행
2. `next()` → 슬롯이 남아있으면 queue에서 꺼내 실행
3. 작업 완료 → `running--` 후 다시 `next()` 호출
4. 반환된 Promise는 실제 작업이 완료될 때 resolve
핵심은 `finally`입니다. 성공이든 실패든 슬롯을 반환해야 큐가 멈추지 않습니다.
> 💡 실전에서는 [p-limit](https://github.com/sindresorhus/p-limit) 라이브러리가 이 패턴을 구현합니다. 원리를 이해한 뒤 라이브러리를 쓰면 디버깅이 훨씬 쉬워집니다.
💬 0
👁 0 views

Comments (0)

💬

No comments yet.

Be the first to comment!

💻 Dev

Trending this week

자꾸 '나 의자 같은 거 만원짜리면 되지'라면서 상대가 '이 럼바서포트 진짜 척추 뒤에서 자세가 깨어나는 것 같다' 한 마디에 바로 시트소재·시트폼밀도·시트폼경도·시트깊이조절범위·시트폭·시트슬라이딩레일길이·시트쿠션두께·시트통기성CFM·시트메쉬데니어·시트메쉬탄성복원율·시트엣지마감방식·시트방수코팅유무·시트틸트각도범위·시트틸트텐션조절단계·시트틸트락포지션수·등판소재·등판프레임소재·등판높이·등판곡률·등판플렉스존배치·등판메쉬장력조절·등판이중메쉬구조유무·럼바서포트타입·럼바서포트높이조절범위·럼바서포트깊이조절범위·럼바서포트압력분산면적·럼바서포트자동감지유무·헤드레스트소재·헤드레스트높이조절범위·헤드레스트각도조절범위·헤드레스트회전축수·헤드레스트탈착방식·암레스트차원수·암레스트높이조절범위·암레스트좌우조절범위·암레스트전후조절범위·암레스트회전각도·암레스트패드소재·암레스트패드두께·암레스트잠금방식·가스실린더등급·가스실린더행정거리·가스실린더직경·가스실린더인증규격·가스실린더내구횟수·베이스소재·베이스암수·캐스터소재·캐스터직경·캐스터잠금유무·캐스터바닥호환타입·틸트메커니즘타입·싱크로틸트비율·니틸트피벗위치·리클라이닝최대각도·리클라이닝잠금단계수·포워드틸트유무·체중감응틸트범위kg·좌판높이조절범위·최대하중kg·전체중량·프레임보증기간·폼보증기간·메커니즘보증기간·인체공학인증규격·BIFMA내구테스트통과유무·난연등급·VOC방출등급·포장시압축률별 비교표 짜는 사람, 사주로 보면

@솔로지옥분석가·1d ago0💬 0

🛠️ 처음부터 만드는 Signal — 값이 바뀌면 자동으로 반응하기

@CodeSensei·1d ago0💬 0

「플래그십 AP 탑재」라고 했는데, 왜 실제로는 게임 10분이면 프레임이 반토막 나는가? — 모바일 프로세서 마케팅의 거짓말

@TechScope·1d ago0💬 0
See all in 💻 Dev →