Threadpool с бесконечными рабочими потоками

Question

У меня есть класс, который реализует бесконечный рабочий поток, например, this, например, в моем случае, представляющем тело. Во время выполнения я буду иметь от 0 до ~ 8 экземпляров в реальном времени в любое время с постоянно создаваемыми и уничтожаемыми экземплярами.

В большинстве случаев этот класс имеет жизненный цикл от 30 секунд до 5 минут, но иногда может быть несколько экземпляров, созданных и уничтоженных за относительно короткий период времени. Именно здесь я склонен сталкиваться с проблемами производительности, учитывая низкую спецификацию аппаратного обеспечения, на котором этот код работает.

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

В основном код у меня есть на данный момент что-то вроде

public class BodyCollection : IReadOnlyDictionary<ulong, TrackedBody> 
{ 
    public void Update() 
    { 
     if (createNew) 
     { 
      var body = new TrackedBody(); 
      body.BeginTracking(); 
      this.Add(1234, body); 
     } 

     if (remove) 
     { 
      TrackedBody body = this[1234]; 
      body.StopTracking(); 
      this.Remove(body); 
     } 
    } 
} 

public class TrackedBody 
{ 
    private readonly Thread _BiometricsThread; 
    private volatile bool _Continue = true; 

    public TrackedBody() 
    { 
     _BiometricsThread = new Thread(RunBiometricsThread); 
    } 

    public void BeginTracking() 
    { 
     _BiometricsThread.Start(); 
    } 

    public void StopTracking() 
    {  
     _Continue = false; 
    } 

    private void RunBiometricsThread() 
    { 
     while(_Continue) 
     { 
      System.Threading.Thread.Sleep(1000); 
     } 
    } 
} 

Так как же я вновь пишу выше, чтобы использовать ThreadPool правильно и так, что я могу отменить запуск темы на ThreadPool по мере необходимости? Я использую CancellationTokens или ManualResetEvents для управления потоками?

Answer 1

Я твердо верю, что вы должны использовать более современные методы асинхронного программирования. Мы будем использовать библиотеки Task Parallel Library здесь, потому что это дает вам возможности, которые вы хотите бесплатно:

• завершение Tracking
• Отмена
• бассейн Thread

---

public class TrackedBody 
{  
    public Task BeginTrackingAsync(CancellationToken cancellation) 
    { 
     return Task.Run(() => RunBiometricsThread(cancellation)); 
    } 

    private void RunBiometricsThread(CancellationToken cancellation) 
    { 
     while(!cancellation.IsCancellationRequested) 
     { 
      Task.Delay(1000, cancellation); 
     } 
    } 
} 

Обратите внимание, что я удалил ключевое слово async. Это ничего не делало само по себе.

Вы можете использовать эту задачу для отслеживания состояния текущей работы. Вы можете использовать токен отмены, чтобы остановить все работы.