Out of Memory Threading - Perf Test Tool

Question

Я создаю инструмент для загрузки теста (отправляет http: GET), и он отлично работает, но в конечном итоге умирает из-за ошибки из памяти.

ASK: Как сбросить потоки, чтобы этот цикл мог непрерывно выполняться, а не ошибаться?

static void Main(string[] args) 
    { 
     System.Net.ServicePointManager.DefaultConnectionLimit = 200; 

     while (true) 
     { 
      for (int i = 0; i < 1000; i++) 
      { 
       new Thread(LoadTest).Start(); //<-- EXCEPTION!.eventually errs out of memory 
      } 
      Thread.Sleep(2); 
     } 
    } 

    static void LoadTest() 
    { 
     string url = "http://myserv.com/api/dev/getstuff?whatstuff=thisstuff"; 

     // Sends http get from above url ... and displays the repose in the console.... 
    } 

Answer 1

Вы инстанцируете Тема оставила справа и в центре. Вероятно, это проблема. Вы хотите заменить

new Thread(LoadTest).Start(); 

с

Task.Run(LoadTest); 

это будет запускать LoadTest на тему в ThreadPool, вместо того, чтобы использовать ресурсы, чтобы создать новую тему каждый раз. ОДНАКО. Затем это вызовет другую проблему.

Темы ThreadPool - это ограниченный ресурс, и вы хотите как можно скорее вернуть потоки в ThreadPool. Я предполагаю, что вы используете методы синхронной загрузки в отличие от методов APM. Это означает, что пока запрос отправляется на сервер, поток, порождающий запрос, спящий, а не собирается выполнять какую-либо другую работу.

Либо использовать (в предположении, .net 4.5)

var client = new WebClient(); 
var response = await client.DownloadStringTaskAsync(url); 
Console.WriteLine(response); 

Или использовать функцию обратного вызова (если не .net 4.5)

var client = new WebClient(); 
client.OnDownloadStringCompleted(x => Console.WriteLine(x)); 
client.BeginDownloadString(url); 

Answer 2

Используйте ThreadPool и использовать QueueUserWorkItem вместо создания тысячи потоков. Нити - дорогие объекты, и неудивительно, что у вас не хватает памяти, и вы не сможете получить какую-либо производительность (в вашем тестовом инструменте) с таким количеством потоков.

Answer 3

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

static void Main(string[] args) 
    { 
     System.Net.ServicePointManager.DefaultConnectionLimit = 200; 
     ThreadPool.SetMaxThreads(500, 300); 
     while (true) 
     { 
      ThreadPool.QueueUserWorkItem(LoadTest); 
     } 
    } 

    static void LoadTest(object state) 
    { 
     string url = "http://myserv.com/api/dev/getstuff?whatstuff=thisstuff"; 
     // Sends http get from above url ... and displays the repose in the console.... 
    }