← Wszystkie zadaniaJavaScript · Senior

runWithLimit: pula obietnic

Napisz funkcję runWithLimit(tasks, limit). tasks to tablica funkcji, z których każda zwraca obietnicę. Uruchom je wszystkie, ale tak, by naraz wykonywało się nie więcej niż limit zadań: gdy jedno się kończy, startuje kolejne.

Zwróć obietnicę z wynikami w kolejności tasks. Jeśli któreś zadanie się nie powiedzie, cała obietnica jest odrzucana tym błędem, a nowe zadania nie są już uruchamiane.

function runWithLimit(tasks, limit) {
  // ...
}

Ctrl+Enter uruchamia testy. Tab robi wcięcie; aby wyjść z edytora klawiaturą, naciśnij Esc, a potem Tab. Kod zapisuje się w tej przeglądarce.

Testy (6)

let active = 0;
let peak = 0;
const task = (v) => async () => { active++; peak = Math.max(peak, active); await wait(20); active--; return v; };
const result = await runWithLimit([1, 2, 3, 4, 5].map(task), 2);
expect(result).toEqual([1, 2, 3, 4, 5]);
expect(peak).toBe(2);

const order = [];
const task = (v, ms) => async () => { await wait(ms); order.push(v); return v; };
const result = await runWithLimit([task('a', 60), task('b', 10), task('c', 10)], 2);
expect(result).toEqual(['a', 'b', 'c']);
expect(order).toEqual(['b', 'c', 'a']);

expect(await runWithLimit([], 3)).toEqual([]);

const error = new Error('fail');
await expect(runWithLimit([async () => 1, async () => { throw error; }], 2)).rejects.toBe(error);

const started = fn();
const tasks = [1, 2, 3].map((v) => () => { started(v); return wait(30).then(() => v); });
const promise = runWithLimit(tasks, 1);
await wait(10);
expect(started).toHaveBeenCalledTimes(1);
expect(await promise).toEqual([1, 2, 3]);
expect(started).toHaveBeenCalledTimes(3);

const started = Date.now();
await runWithLimit([1, 2, 3, 4].map(() => () => wait(40)), 4);
expect(Date.now() - started < 120).toBe(true);