Есть ли в C# возможность дождаться выполнения всех задач, которые были добавлены в очередь на выполнение в пул потоков?

Question

[Bur-Burito]

Есть метод, который при определенном условии сам себя рекурсивно добавляет в очередь на выполнение в ThreadPool-е. Возможно ли как-то оттенить конец выполнения последнего таска в этой очереди?

Answer 1

[Axian Ltd.]

Видимо документацию нынче читать не модно (https://msdn.microsoft.com/en-us/library/system.th...

GetAvailableThreads(Int32, Int32) - Retrieves the difference between the maximum number of thread pool threads returned by the GetMaxThreads method, and the number currently active.

Дальше, надеюсь, догадаешься сам.

Comments

[Bur-Burito]

Об этом думал, но когда задавал вопрос, надеялся, что есть более элегантный и естественный подход

[Axian Ltd.]

Куда уже более естественно чем получить количество активных потоков у апи потоков. А вам как хотелось?

[Bur-Burito]

Axian Ltd.: надеялся, что возможно есть что-то похожее на WaitAll, но со ссылкой на очередь ожидающих задач

[Axian Ltd.]

Никто не мешает написать такую штуку использовав GetAvailableThreads.

Answer 2

[MonkAlex]

В абстрактном понимании - нельзя.
А так - что вам мешает делать это в том же методе, который ставит в очередь? Делаете ContinueWith и пишете обработку на "после выполнения", с обработкой в нужном виде.

Comments

[Bur-Burito]

При таком подходе, если я правильно понял, вызывающий метод будет занимать поток, пока закинутые им в очередь таски не выполняться, что в случае многократного рекурсивного вызова метода не очень хорошо.

Answer 3

[Артем]

Может, сделать как-то так?

int working_tasks = 0;
ManualResetEventSlim pre = new ManualResetEventSlim(false);

// здесь запуск тасков
// в каждом таске (в начале) ставим working_tasks = Interlocked.Increment(working_tasks);
// в конце - if(Interlocked.Read(working_tasks) == 0) { pre.Set(); }

pre.Wait();

// здесь то, что должно выполняться после выполнения всех тасков

Таким образом, в начале выполнения таска увеличиваем некую переменную на 1, в конце - уменьшаем на 1. Если все таски выполнены (переменная равна 0) - ставим флаг резет-ивента - и начинает выполняться код после pre.Wait().
Не уверен в правильности (писал по памяти), но идея вроде рабочая. Поправьте, если я не прав.

Comments

[Bur-Burito]

Спасибо за ответ!
Подобный подход предложил Axian Ltd. С помощью GetAvailableThreads(Int32, Int32) можно получить количество незанятых потоков в пуле

[Артем]

Ну, кстати да, похоже.