Решение тестовго задания "Планировщик задач"

• Каждая отдельная задача выглядит следующим образом:

  interface ITask {
    targetId: number
    action: 'init' | 'prepare' | 'work' | 'finalize' | 'cleanup'
  }
  

• Есть специальный класс Executor (src/Executor.ts), который умеет исполнять одну задачу:

  Executor.executeTask(task: ITask): Promise<void>
  

Надо реализовать асинхронную функцию, которая получает на вход очередь задач AsyncIterable<ITask> и максимальное кол-во одновременных "потоков" maxThreads и возвращает промис, который будет разрезолвлен, когде все задачи отработают.

async function run(executor: IExecutor, queue: AsyncIterable<ITask>, maxThreads = 0): Promise<{...}>

При maxThreads == 0 ограничения на кол-во одновременных "потоков" нету.

Функция должна исполнить задачи максимально быстро, стараясь как можно больше задач исполнить параллельно. Но, есть ограничение (в нем заключается основная сложность задачи): в один момент времени Executor не может исполнять несколько разных задач с одним и тем же Task.targetId, но при этом он может исполнять много разных задач с разными Task.targetId параллельно.

При взятии задачи из очереди (вызов iterator.next() или итерация через for ... of) она автоматически удаляется из очереди, при этом существующие итераторы не инвалидируются. При этом надо учесть, что очередь может быть пополнена во время исполнения задач, а также, никто не гарантирует, что очередь конечна в принципе.

Критерий остановки исполнения функции run(): все полученные из очереди задачи выполнены и в очереди больше нету новых новых задач.

Все задачи для одного и того же ITask.targetId должны быть исполнены последовательно в том порядке, в котором они находятся в очереди.

Решение находится в файле run.ts

Настройка окружения:

• Node.js version >= 12

Установка и подготовка

npm install

npm i --save-dev nyc npm test

Самостоятельная проверка работоспособности

Для удобства я написал тесты для run(), которые проверяют правильность её работы.

npm run test

Также тесты генерят детальные отчеты-логи ./test/*.log.html.