QuestQueue

صف کارهای ناهمگام با هم‌زمانی محدود. در هر لحظه دست‌بالا simultaneous کار اجرا می‌شود؛ بقیه می‌مانند و با پایان هر کار، جایی خالی پر می‌شود. برای بارگذاری‌ها یا درخواست‌های دسته‌ای به کارش ببرید: هر چیزی که نمی‌توانید یکجا رها کنید.

API

new QuestQueue({ simultaneous })

نمونه

import { QuestQueue } from 'ranuts';

const queue = new QuestQueue({ simultaneous: 3 });
const results = await Promise.all(urls.map((url) => queue.add(() => fetch(url))));

// یا رها کنید و بروید، سپس چشم‌به‌راه همه بمانید، شکست‌ها هم در میان
urls.forEach((url) => queue.add(() => fetch(url)).catch(report));
await queue.onIdle();

یادداشت‌ها

1. اولین ورودی، اولین خروجی: کارها به ترتیبی که افزوده شده‌اند اجرا می‌شوند.
2. یک شکست صف را نمی‌خواباند. هر کار تنها Promise خودش را رد می‌کند و کار بعدی به‌هر‌روی آغاز می‌شود.
3. کاری که همگام خطا پرتاب کند هم گرفته می‌شود، پس نمی‌تواند از add() بیرون بزند و شمارندهٔ هم‌زمانی را گیر بیندازد.
4. allSettled ترتیب ورودی را نگه می‌دارد و هر پیامد را جداگانه گزارش می‌کند.