只需一个hpp你就可以写出这样的协程代码
MyTask<bool> myTask() { //在工作线程work_thread中请求数据库，返回给主线程main_thread auto cursor = co_await MongoFind<work_thread,main_thread>(...); //在主线程中完成其他工作吧 while (auto* o = cursor.fetch()){ //..... } //send(...); }此hpp只需要asio和c++20,当然也可以看我的hpp代码修改出你的版本
需要gcc版本11 + 推荐使用WinLibs测试 https://winlibs.com/
测试安装方法：
cd dep python build.py cd .. mkdir build cd build #cmake -G"your build tools" .. #example mingw cmake -G"MinGW Makefiles" .. make install cd .. #./coro_test coro_test.exe #gcc编译需要添加参数 -std=c++20 -fcoroutines #vs2017编译需要添加参数 /await 超简单的使用方法 example:
#include <asio/asio.hpp> #include "Task.hpp" const int WORK_THREAD_COUNT = 8; //工作线程数 asio::io_context main_thread(1);//你的主线程io_context asio::io_context work_threads(WORK_THREAD_COUNT);//你的工作线程io_context //必须定义一线程全局变量g_current_thread，并在每个线程创建时赋值为对应的io_context指针 thread_local asio::io_context* g_current_thread = &main_thread; using namespace nicehero; //开始创建一个可以co_await的协程吧 //execute 为你执行时希望的线程，return_context 为你返回后回到的线程 template<asio::io_context& execute, asio::io_context& return_context> Task<int, execute, return_context> coro_add(int x, int y)//一个返回int的模板协程 { //在你希望的线程中执行任务吧 std::cout << "do coro_add in thread_id=" << std::this_thread::get_id() << std::endl; int r = x + y; co_return r; } typedef Task<bool,main_thread> MyTask; int main() { g_current_thread = &main_thread; //创建工作线程并给g_current_thread赋值 for (int i = 0; i < WORK_THREAD_COUNT; ++i) { std::thread t([] { g_current_thread = &work_threads; asio::io_context::work work(work_threads); work_threads.run(); }); t.detach(); std::this_thread::sleep_for(std::chrono::milliseconds(50)); } //do 一些初始化逻辑 //创建一个主线程任务 (不需post,协程开始后会自动往相应的线程post出去) auto f = []()->MyTask { //-------主线程开始------ std::cout << "step1: now thread_id=" << std::this_thread::get_id() << std::endl; //切换到工作线程执行coro_add,返回后不切换线程 int x = co_await coro_add<work_threads, work_threads>(1, 2); //返回后还处于此线程 std::cout << "step2: now thread_id=" << std::this_thread::get_id() << std::endl; //切换到工作线程执行coro_add,完成后返回主线程 (使用coro_add的默认模板参数) int y = co_await coro_add(3, 4); //-------回到主线程------ std::cout << "step3: now thread_id=" << std::this_thread::get_id() << std::endl; co_return true; }; //执行协程任务 f(); //如果任务中没有co_await,co_return,Task也可以作为一个普通函数使用 main_thread.post([]()->MyTask { return true; }); main_thread.run();// return 0; } //这是错误的! Task<...> a(...){ ... co_return ... } Task<...> b(...){ ... auto v = co_await a(...); ... co_return ... } Task<...> c(...){ ... auto v = co_await b(...); ... co_return ... }