c++ - 在使用将来的wait_for时无法检查成员变量，但是如果我在线程中 sleep ，它将起作用

我正在使用std::future和wait_for()设置超时，等待Zookeeper连接完成。
我一直在线程的while循环中检查connected_。如果我不在循环中睡觉，wait_for()总是返回超时，但是我确定connected_已经设置。
如果我在while循环中睡了几毫秒，那么效果很好。 connection_timeout_的时间足够长。那么我的代码有什么问题呢？

std::future<int> fut = std::async(std::launch::async, [this]{
      while(true){
        usleep(1000);//if delete this line, I get timeout always
        if(connected_){
          return 0;
        }
      }
    });
    auto status = fut.wait_for(std::chrono::duration<int, std::milli>{connection_timeout_});

    if(status == std::future_status::deferred){
      LOGGER_ERROR(Log::GetLog(), "wait for zk connection: deferred");
      return -1;
    }else if(status == std::future_status::timeout){
      LOGGER_ERROR(Log::GetLog(), "wait for zk connection: timeout");
      return -1;
    }else{// status == std::future_status::ready
      LOGGER_INFO(Log::GetLog(), "wait for zk connection: connected");
    }

最佳答案

您的代码对我来说似乎还可以。罪魁祸首可能是没有始终在超时之前设置connected_。这是一个测试代码:

std::atomic<bool> connected_ = false;
std::chrono::milliseconds connection_timeout_ = std::chrono::milliseconds(100);

struct foo {

    std::future<int> fut = std::async(std::launch::async, [this] {
        while (true) {
            std::this_thread::sleep_for(std::chrono::microseconds(1000));
            if (connected_) {
                return 0;
            }
        }
    });
};


int main()
{
    foo f;
    std::thread([]() {
        std::this_thread::sleep_for(std::chrono::milliseconds(50)); // connected_ set set after:  500 = timeout , 50 = connected
        connected_ = true;
    }).detach();

    auto status = f.fut.wait_for(std::chrono::duration<int, std::milli>(connection_timeout_));


    if (status == std::future_status::deferred) {
        std::cout<<  "wait for zk connection: deferred\n";
        return -1;
    }
    else if (status == std::future_status::timeout) {
        std::cout << "wait for zk connection: timeout\n";
        return -1;
    }
    else if ( status == std::future_status::ready) {
        std::cout << "wait for zk connection: connected\n";
    }
    return 0;
}

关于c++ - 在使用将来的wait_for时无法检查成员变量，但是如果我在线程中 sleep ，它将起作用，我们在Stack Overflow上找到一个类似的问题：https://stackoverflow.com/questions/55720290/