c++ - 如果超时已过，如何中止 async()

Question

我对 async() 函数或任何其他解决问题的方法有疑问。我向服务器发送指定类型的消息，然后等待特定的回复。我有函数 receive() 等待服务器的响应。我在 async() 中调用这个函数。

代码示例:

while (true) {
    future_receive = std::async(std::launch::async, [&] {
        receive();
    });

    do {
        status = future_receive.wait_for(chrono::seconds(timeLimit));
        if (status == std::future_status::timeout){
            //if timeout, abort async() function
        }
    } while (status != std::future_status::ready);
}

我的问题是什么？在这种情况下，如果我得到“超时”，async() 函数将继续工作，会一直等到有东西来了，即使它永远不会来，并且在下一个循环中会再次被调用，并且将创建新线程。如何避免这种情况？

我如何在“超时”结束时中止 async()。也许没有 async() 的任何其他方式来解决这个问题。我只想使用 C++ 的标准库？

Answer 1

异步线程必须合作并检查它是应该继续工作还是放弃，没有可移植的方式强制它在没有合作的情况下停止。

一种方法是将 receive() 调用替换为具有超时的类似调用，并让线程在超时后放弃，或者在超时后检查标志以是否继续。

while (true) {
    std::atomic<bool> stop{false};
    future_receive = std::async(std::launch::async, [&] {
        while (!stop)
          try_receive(std::chrono::seconds(1));
    });

    do {
        status = future_receive.wait_for(chrono::seconds(timeLimit));
        if (status == std::future_status::timeout){
            stop = true;
        }
    } while (status != std::future_status::ready);
}

现在异步线程最多只会阻塞一秒钟，然后会检查是否被告知放弃，否则会再次尝试接收。

如果您愿意牺牲可移植性，像这样的东西应该可以在 std::thread 是根据 POSIX 线程实现的平台上工作:

while (true) {
    std::atomic<pthread_t> tid{ pthread_self() };
    future_receive = std::async(std::launch::async, [&] {
        tid = pthread_self();
        receive();
    });

    do {
        status = future_receive.wait_for(chrono::seconds(timeLimit));
        if (status == std::future_status::timeout){
            while (tid == pthread_self())
            { /* wait for async thread to update tid */ }
            pthread_cancel(tid);
        }
    } while (status != std::future_status::ready);
}

这假定在 receive() 调用中某处有一个 Pthreads 取消点，以便 pthread_cancel 将中断它。

(这比我想要的稍微复杂一些。最初有必要在原子中存储一些已知值，以便处理当调用线程超时并尝试异步线程尚未开始运行的情况取消它。为了处理这个问题，我存储了调用线程的 ID，然后在调用 pthread_cancel 之前等待它发生更改。)