如何使用活动线程从while循环中中断

Question

我知道这不是表达我的问题的最佳方式。在我的服务器中，一些问题基本上归结为 - 一旦满足条件A，你如何打破while循环？如果满足条件B，是否可以销毁特定线程？

不幸的是，除非我能从循环中中断，否则主线程被 recvfrom() 函数永远阻塞了。

while (1)
{
  recBytes = recvfrom(sock, packetBuff, 8, 0, (struct sockaddr *) &client, &SockLength);

  std::thread TX([&] 
  {
    //process packet task

    if(conditionA == 1)
      break from while loop

    if(conditionB == 1)
      destroy any active threads spawned by TX

    .
    .
    .
    much more tasks

  });

  TX.detach();
} 

.
.
.
continue rest of code

提前致谢！

Answer 1

中断阻塞 I/O 调用的标准方法是用 select()/poll()/etc 替换它，等待 2 个套接字：您的数据套接字和非阻塞通知管道。如果 select() 报告您可以读取或写入数据套接字，那么您就可以以非阻塞方式执行此操作。如果它报告通知管道上有可用的数据，则您会中断循环。任何线程都可以将单个字节写入非阻塞通知管道，以导致另一个线程中的 select() 返回。

至于销毁其他线程，如果没有这些线程的合作，您就无法做到这一点。基本上，您需要一种方法来通知他们需要退出。如果这些线程不进行阻塞调用，那么一个带有定期检查的简单原子标志就可以了。否则，您需要一种方法来中断阻塞调用。如果是 I/O 调用，则引入另一个通知管道。如果它在条件变量上阻塞，请使用 std::condition_variable::notify_all()。