Promise Resolve 큐잉을 통한 JavaScript 비동기 생산자-소비자 패턴 구현

Context

데이터 송신 속도가 수신 속도를 상회하는 Webhook, WebSocket 환경에서 발생하는 데이터 유실 및 처리 병목 현상 분석. 단순 비동기 호출만으로는 처리 가능한 임계치를 초과하는 트래픽 제어가 불가능한 구조적 한계 존재.

Technical Solution

• Producer-Consumer 패턴을 적용한 Mailbox Queue 클래스 설계
• Promise의 resolve 함수를 waiters 배열에 저장하여 비동기 실행 제어권을 외부로 추출하는 메커니즘 구현
• pop() 호출 시 메시지 부재 시 Promise를 반환하여 Consumer의 실행을 일시 중단(Pause)시키는 상태 관리
• push() 호출 시 waiters 큐의 최상위 resolve 함수를 트리거하여 대기 중인 Consumer를 즉각 깨우는 이벤트 기반 구조
• Symbol.asyncIterator 인터페이스 구현을 통한 for await...of 루프 기반의 직관적인 메시지 소비 환경 제공
• close() 메서드를 통한 모든 대기 Promise의 null resolve 처리로 Graceful Shutdown 보장