-
Каждая отдельная задача выглядит следующим образом:
interface Task { targetId: number action: 'init' | 'prepare' | 'work' | 'finalize' | 'cleanup' }Использовать специальные хуки
_onCompleteили_onExecuteнельзя, они используются для диагностики и логирования. -
Есть специальный класс
Executor(src/Executor.ts), который умеет исполнять одну задачу:Executor.executeTask(task: Task): Promise<void>В решении нельзя использовать внутреннее состояние
Executor, толькоIExecutor.executeTask().
Надо реализовать асинхронную функцию, которая получает на вход очередь
задач Iterable<Task> и максимальное кол-во одновременных "потоков" maxThreads и возвращает промис, который будет разрезолвлен, когде все задачи
отработают.
async function run(queue: Queue, maxThreads = 0): Promise<{...}>
При maxThreads == 0 ограничения на кол-во одновременных "потоков" нету.
Функция должна исполнить задачи максимально быстро, стараясь как можно больше задач исполнить параллельно. Но, есть ограничение (в нем заключается основная сложность задачи): в один момент времени Executor не может исполнять несколько разных задач с одним и тем же Task.targetId, но при этом он может исполнять много разных задач с разными Task.targetId параллельно.
-
Например, если мы вызовем
executor.executeTask({ targetId: 0, action: 'init' }); executor.executeTask({ targetId: 0, action: 'prepare' });то, второй вызов кинет исключение.
-
При этом
executor.executeTask({ targetId: 0, action: 'init' }); executor.executeTask({ targetId: 1, action: 'prepare' });или
await executor.executeTask({ targetId: 0, action: 'init' }); await executor.executeTask({ targetId: 0, action: 'prepare' });отработают нормально.
При взятии задачи из очереди (вызов iterator.next() или итерация через for ... of) она автоматически удаляется из очереди, при этом существующие итераторы не инвалидируются. При этом надо учесть, что очередь может быть пополнена во время исполнения задач, а также, никто не гарантирует, что очередь конечна в принципе.
Критерий остановки исполнения функции run(): все полученные из очереди задачи выполнены и в очереди больше нету новых новых задач.
Все задачи для одного и того же Task.targetId должны быть исполнены последовательно в том порядке, в котором они находятся в очереди.
Node.js version >= 12
npm install
- Заготовка для функции
run()лежит в./src/run.ts. - Никакие другие файлы, кроме
./src/run.tsменять нельзя. - Обвязочный код в
run.tsменять нельзя - Внутри одного вызова
run()создавать дополнительные эксземплярыExecutorнельзя.
Для удобства я написал тесты для run(), которые проверяют правильность её работы.
npm run test
Также тесты генерят детальные отчеты-логи ./test/*.log.html.