TPL threads count

Question

У меня возник вопрос о программистах .NET 4.0 TPL. Я создал этот тестер стресса TPL и ThreadPool, где я запускаю тесты X, каждый тест выполняет Y количество задач, когда заканчивается, он продолжает следующий тест.

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

(Количество потоков, которые я взял, взято из Resource Monitor).

псевдо-код:

while (tasksLeftToRun != 0) 
{ 
    var nextTask = new Task(new Action(()=> 
    { 
     Thread.Sleep(20); 
    }), cancellationToken); 

    nextTask.Start(); 
    nextTask.ContinueWith((t) => 
    { 
     //... 
    },TaskScheduler.Default); 
    tasksLeftToRun--; 
} 

около 15 секунд после того, как приложение завершит с испытаниями, количество нитей падает до ~ 7.

Спасибо!

Answer 1

Проблема в том, что вы используете Thread.Sleep вместо фактической работы, поэтому ThreadPool видит, что вы заблокировали потоки и запускаете новые потоки. Это приведет к тому, что количество потоков будет расти со временем.

Если вы должны были выполнять настоящую работу, а не просто спать, этого не произошло бы, поскольку ThreadPool увидит, что потоки фактически выполняют работу, а новые потоки не ускоряют общую пропускную способность.

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

while (tasksLeftToRun != 0) 
{ 
    var nextTask = new Task.Factory.StartNew(()=> 
    { 
     //... Actual work 
    }), cancellationToken); 

    tasksLeftToRun--; 
} 

Однако, как это кажется, что вы работаете над «очередью» задач (у вас так много задач для создания), вы можете изучить, подходит ли класс Parallel для этого. Если «работа» хранится в какой-либо форме сбора, использование Parallel.ForEach или даже PLINQ может быть более уместным.