c++ - 使用异步boost asio代码进行同步操作

Question

我有一个服务器和一个用 boost ASIO 编写的客户端代码，它工作得很好。 由于同步和异步 boost asio API 不同，我为异步通信编写的代码是否有可能以同步方式而不是异步方式运行和工作。 ？

Answer 1

您可以在专用的 io_service 上运行任何异步代码，并简单地运行服务阻塞:

Live On Coliru

#include <boost/asio.hpp>
#include <boost/asio/high_resolution_timer.hpp>
#include <iostream>

using namespace std::chrono_literals;
using namespace boost::asio;
using boost::system::system_error;

io_service svc;
high_resolution_timer deadline(svc, 3s);

void task_foo() { 
    deadline.async_wait([](system_error) { std::cout << "task done\n"; });
}

int main() {
    task_foo();

    std::cout << "Before doing work\n";

    svc.run(); // blocks!

    std::cout << "After doing work\n";
}

打印

Before doing work
task done
After doing work

或者:

您始终可以使用可以等待阻塞的 future :

Live On Coliru

#include <boost/asio.hpp>
#include <boost/asio/high_resolution_timer.hpp>
#include <boost/make_shared.hpp>
#include <future>
#include <iostream>
#include <thread>

using namespace std::chrono_literals;
using namespace boost::asio;
using boost::system::system_error;

io_service svc;
high_resolution_timer deadline(svc, 3s);

std::future<int> task_foo() {
    auto p   = boost::make_shared<std::promise<int> >();
    auto fut = p->get_future();

    deadline.async_wait([p](system_error) {
        std::cout << "task done\n";
        p->set_value(42);
    });

    return fut;
}

int main() {

    auto foo = task_foo();

    std::cout << "Before doing work\n";

    std::thread([] { svc.run(); }).detach(); // doesn't block!

    std::cout << "After starting work\n"; // happens before task completion

    auto result = foo.get(); // blocks again!

    std::cout << "Task result: " << result << "\n";
}

打印

Before doing work
After starting work
task done
Task result: 42

这样您仍然可以同时运行 io_service 并且不需要它完成，即使特定任务同步完成(foo.get())