c# - 告诉“其他”任务在C#中暂停

我有以下几点：

[TestMethod]
public async Task Start()
{
   var numDrivers = 2;
   List<Task> tasks = new List<Task>();
   var motherDriver = GetMotherDriver();
   while (numDrivers != 0)
   {
       var rnd = new Random();
       var r = rnd.Next(itemArray.Count);

       var target = itemArray[r];
       var proxyDriver = GetProxiedDriver();

       tasks.Add(Task.Run(() => HandleIntro(proxyDriver)));
       numDrivers--;
   }

   await Task.WhenAll(tasks);
}

这是可行的，但是每隔一段时间，HandleIntro会遇到需要重置motherDriver的错误。通常，如果proxyDriver中的一个命中这种情况，则所有这些立即出现。我需要防止motherDriver多次重生，因此我尝试使用布尔isPaused和while循环来管理它。在HandleIntro中，我尝试使用第一个Task设置的全局变量来告诉其他任务暂停直到完成：

 private bool _isPaused;

 private async Task Start(){
   _isPaused = false;
   //code
 }

 private async Task HandleIntro(Driver driver) {
       // wait for isPaused to get set to false
       while(_isPaused){}
       // do stuff
       if(errorOccurs){
           FixProblem();
       }
 }

 private void FixProblem(){
         if (!_isPaused){
             _isPaused = true;
             // spawn new motherDriver
             _isPaused = false;
         } else{
             // hold here until other thread sets isPaused = false
             while (_isPaused){}
          }
 }

但是编译器告诉我while (_isPaused)中的FixProblem始终是true-好像它看不到某个时刻该值将由另一个线程设置。这告诉我，我将以错误的方式进行操作。这是正确的方法吗？如何正确处理呢？

最佳答案

您正在各个任务之间共享_isPaused变量。这样，当一项任务更改了变量的值时；所有线程都进入新的motherDriver初始化过程。

您需要同步对重新启动motherDriver控制块的访问，以确保只有一个线程可以重新启动该进程。尝试类似的东西：

private static object objectlock = new object();

private void FixProblem(){
   lock(objectlock)
   {
      if (!_isPaused && motherDriverNeedsTobeRestarted){
         _isPaused = true;
         // spawn new motherDriver
         _isPaused = false;
      }
   }
}

这样可以确保在出现问题时motherDriver在任务关闭之前重新启动。