2503C++,C++标准的执行

最优雅的应该是c++26刚刚引入的std::execution,通过sender/receiver模型和常用的异步算法来简化调用异步逻辑,还可随时改成协程.

#include <stdexec/execution.hpp>
#include <exec/static_thread_pool.hpp>
int main()
{exec::static_thread_pool pool(3);auto sched = pool.get_scheduler();auto fun = [](int i) { return i*i; };auto work = stdexec::when_all(stdexec::starts_on(sched, stdexec::just(0) | stdexec::then(fun)),stdexec::starts_on(sched, stdexec::just(1) | stdexec::then(fun)),stdexec::starts_on(sched, stdexec::just(2) | stdexec::then(fun)));auto [i, j, k] = stdexec::sync_wait(std::move(work)).value();std::printf("%d %d %d\n", i, j, k);
}

可直接改成协程:

#include <stdexec/execution.hpp>
#include <exec/static_thread_pool.hpp>
#include <exec/task.hpp>
exec::task<std::tuple<int, int, int>> Work(auto& scheduler) {auto fun = [](int i) { return i*i; };auto work = stdexec::when_all(stdexec::on(scheduler, stdexec::just(0) | stdexec::then(fun)),stdexec::on(scheduler, stdexec::just(1) | stdexec::then(fun)),stdexec::on(scheduler, stdexec::just(2) | stdexec::then(fun)));co_return co_await work;
}
int main()
{exec::static_thread_pool pool(3);auto scheduler = pool.get_scheduler();auto work = Work(scheduler);auto [tp] = stdexec::sync_wait(std::move(work)).value();assert(tp == std::tuple<int, int, int>(0, 1, 4));
}

当前stdexec库把std::execution实现得比较完整,如何实现自己的调度器的文档还不多,可直接用stdexec现成的设施就可完成需求:

执行库
其它的也还有现成又简单的协程库可满足你的需求,如libfork:

#include "libfork/core.hpp"
inline constexpr auto fib = [](auto fib, int n) -> lf::task<int> {if (n < 2) {co_return n;}int a, b;co_await lf::fork[&a, fib](n - 1);//生成子任务.co_await lf::call[&b, fib](n - 2);//执行子内联.co_await lf::join;//等待子.co_return a + b;//加入后可安全读取.
};

分支库
另外还有concurrentcpp的使用也非常简单,如果要从源码开始学习我发现最简单的就是它:
并行源码

上面这几个库都不是全家桶,很容易引入.如果要那种全家桶的,优秀的也有不少,如boost,folly等等.最近大火的deepseek3fs使用的协程库就是folly中的.