C++ 终止等待 std::thread

Question

我的辅助线程监听 channel 兔子，并希望在我调用方法 stopListen() 时将其从主线程中删除。

void PFClient::startListen()
{
this->stop = false;
this-> t = thread(&PFClient::callback,this);    
}

void PFClient::callback()
{
PFAPIResponse* response;
char * temp;
    while (!this->stop)
    {
        try
        {

            std::string receiver_data = "";
            //std::wcout << L"[Callback] oczekiwanie na wiadomość !" << endl;
            receiver_data = this->channel->BasicConsumeMessage()->Message()->Body();
            temp = &receiver_data[0];
... some operation with received data

void PFClient::stopListen()
{
this->stop = true;
}

信号量无法正常工作，因为它只有在收到下一条消息后才会工作。我尝试 detach(),terminate() 但没有用。我怎样才能残酷地杀死这个过程？

Answer 1

正如我在评论中已经建议的那样，您可以使用无阻塞功能。

如果您使用的图书馆不提供它，那么 async可能是一个有效的选择:

while (this->stop == false) {
  auto receiver_data = std::async(/* ... address function and object*/);

  // wait for the message or until the main thread force the stop
  while (this->stop == false &&
         (receiver_data.wait_for(std::chrono::milliseconds(1000) == std::future_status::timeout))
    ;

  if (this->stop == false && receiver_data.vaild() == true) {
    // handle the message
  }
}