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

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 должны быть исполнены последовательно в том порядке, в котором они находятся в очереди.

задачка на тестовом стоит ее пробовать решить?

жесть, это на какую позицию?

https://hh.ru/vacancy/82991861?hhtmFrom=chat

Пздц

interface Task { targetId: number; action: string; execute: () => Promise<void>; } class TaskQueue { private queue = new Map<number, Task[]>(); addTask(task: Task) { if (!this.queue.has(task.targetId)) { this.queue.set(task.targetId, []); } this.queue.get(task.targetId)!.push(task); } async runTasksInQueue() { const tasks = Array.from(this.queue.values()).flat(); await Promise.all(tasks.map(task => task.execute())); this.queue.clear(); } } class TaskRunner { constructor(private maxThreads: number, private taskQueue: TaskQueue) {} async addTask(task: Task) { this.taskQueue.addTask(task); const pendingTaskCount = this.taskQueue.size(); if (pendingTaskCount >= this.maxThreads) { await this.taskQueue.runTasksInQueue(); } } async finalize() { if (this.taskQueue.size() > 0) { await this.taskQueue.runTasksInQueue(); } } }

Всего 800 и в Москве с такими знаниями это галера какая-то

3 этапа отбора еще на эту помойку

О а я его даже сделал, для этой компании )) правда у меня очень странный касяк был: На моем компе с линуксом у меня все предоставленные в задании тесты проходили а вот на маках проверяющих тесты на производительность не прошли )) Ну и собез я у них в этом году завалил )))