在长时间运行的任务中运行 while 循环时 CPU 已达到最大值

Question

我正在对消息传递服务器进行持续轮询。当消息到达服务器时，我抓取消息并处理它。不幸的是，这是一个简单的任务使用 80-100% 的 CPU。 更新：我已将其简化为 while 循环本身。 10 个任务中的 while 循环导致 CPU 以 100% 轻松达到最大值。

    int i = 0;
    while(true){
     //At the start of every minute
       if (DateTime.Now.Seconds == 0)
      {
        i++;
      }
    }

有没有一种方法可以限制循环，或者有更好更好的方法来编写此代码，使其不使用 100% 的 CPU？我曾尝试添加 1 秒的 Task.Delay，但这并没有多大帮助。

如果您能提供任何帮助或建议，我将不胜感激。

// First I poll 10 different locations for messages and each task polls its own queue
foreach(Queue queue in queueList)
{
task.Add(Task.Run(() => PollIndividualQueue(queue));
}

t= Task.WhenAll(task.ToArray()).WithAggregatedExceptions();
t.Wait();

//Then in the PollIndividualQueue method I implement the while loop that constantly polls a message queue for the next hour
private async Task<string> PollIndividualQueue(Queue queue)
{
    var cancellationToken = new CancellationTokenSource(Timespan.FromMinutes(60)).Token;

  while(!cancellationToken.IsCancellationRequested)
   {
       //Poll the queue and if there is a message grab it and process it
       if(!await GetMessage())
        {
           //I call a stored procedure that inserts this message into the database.
         using(var conn = new SqlConnection(...)
        {
           using(var cmd = new SqlCommand(MyStoredProc, conn)
               {
                cmd.CommandType = Command.StoredProcedure;
                  cmd.Parameters.Add(new SQlParameter(...InputMessage));
                await conn.OpenAsync();
                await cmd.ExecuteNonQueryAsync();
             }
            }
            }
        else
        {
          await Task.Delay(1000);
        }
   }

}

private Task<bool> getMessage(Queue queue)
  {
   object myLock = new object();

   
      try
      {
        Monitor.Enter(myLock);
        queue.Get(message);
      }
      catch(MQException ex)
      {
       if(ex.ReasonCode == 2033)
       {
         return false;
       }
      }
     finally
     {
       Monitor.Exit(myLock);
     }    
}

编辑：谢谢大家的 cmets，但它似乎偏离了实际问题。问题是有没有办法使用总 CPU 的百分比？ 我可以从字面上将所有这些代码从 While 循环中取出，并且 CPU 仍处于 100%。 while 循环似乎是驱动 CPU 负载的原因。

Answer 1

好的。很明显，你是新手，所以我会尽量善待我的cmets。

1. 您的问题顶部的 while 循环是非常糟糕的编程。您想知道为什么它会耗尽您的 CPU 吗？如果您在 Intel i9-9900K 上运行，那么该循环将每 秒 执行数十亿次。我不是在开玩笑！！

2. 如果你想每秒做一次，那么你需要做一个简单的时间计算然后睡觉。为了让 CPU 安静下来，你的代码应该是：

   int i = 0;
   while (true) {
      //At the start of every minute
      Thread.Sleep((int)(60000 - ((DateTime.Now.Ticks / TimeSpan.TicksPerMillisecond) % 60000)));
      i++;
   }
   

3. 我真的不明白你在 getMessage 方法中使用了锁。 Queue 的 Get 方法在尝试检索消息时会阻塞。

4. 如果您要使用线程，那么为什么不让每个线程单独连接到队列管理器，因为没有理由在线程之间共享连接。