C++如何实现协程 C++协程的基本实现与使用-C++-PHP中文网

C++如何实现协程 C++协程的基本实现与使用

冰火之心

发布： 2025-06-19 11:45:01

原创

701人浏览过

c++++协程是一种允许函数暂停并在稍后恢复执行的机制，它不是线程，而是一种用户态轻量级线程。1. 定义promise_type以管理协程状态、返回值和异常；2. 创建awaitable对象控制协程的暂停与恢复；3. 使用co_return、co_yield、co_await控制流程。优势在于性能高、无需锁、适合io密集型任务，劣势是不能利用多核且阻塞影响整个线程。处理异常时通过unhandled_exception捕获并传递给调用者，使用co_yield可实现生成器用于大型数据集处理、惰性求值、数据流管道及异步编程等场景。

C++如何实现协程 C++协程的基本实现与使用

C++协程，简单来说，就是一种允许函数暂停执行并在稍后恢复执行的机制。它不是线程，而是一种用户态的轻量级线程，可以在单个线程内实现并发，避免了线程切换的开销。

C++20正式引入了协程，但在此之前，已经有一些库（例如Boost.Coroutine）提供了类似的功能。现在，我们有了标准的支持，实现起来更加方便和高效。

C++20协程依赖于三个核心概念：promise、coroutine handle和awaitable。

立即学习“C++免费学习笔记（深入）”；

解决方案

要实现C++协程，大致需要以下步骤：

定义promise_type： 这是协程的核心，负责管理协程的状态、返回值和异常。它需要提供get_return_object()、initial_suspend()、final_suspend()、unhandled_exception()和return_value()等方法。
创建awaitable对象： awaitable对象定义了await_ready()、await_suspend()和await_resume()三个方法，用于控制协程的暂停和恢复。
使用co_return、co_yield和co_await： 这些关键字用于在协程内部控制流程。co_return用于返回值并结束协程，co_yield用于生成序列中的一个值（通常用于生成器），co_await用于暂停协程，等待awaitable对象完成。

一个简单的例子：

ViiTor实时翻译

AI实时多语言翻译专家！强大的语音识别、AR翻译功能。

116

查看详情

#include <iostream>
#include <coroutine>

struct ReturnObject {
    struct promise_type {
        ReturnObject get_return_object() { return {}; }
        std::suspend_never initial_suspend() { return {}; }
        std::suspend_always final_suspend() noexcept { return {}; }
        void unhandled_exception() {}
        void return_void() {}
    };
};

ReturnObject MyCoroutine() {
    std::cout << "Coroutine started\n";
    co_await std::suspend_always{};
    std::cout << "Coroutine resumed\n";
    co_return;
}

int main() {
    auto coro = MyCoroutine();
    std::cout << "Main function\n";
    return 0;
}

登录后复制

这个例子只是一个非常基础的框架，它演示了如何定义一个最简单的协程。实际应用中，你需要根据具体需求实现更复杂的promise_type和awaitable。

C++协程的优势是什么？相比于线程，它有哪些优势和劣势？

协程最大的优势在于其轻量级和高效性。由于协程是在用户态进行切换，避免了内核态的线程切换开销，因此性能更高。此外，协程通常比线程更容易管理，因为它们共享相同的地址空间，避免了线程间的同步和锁竞争问题。

劣势在于，如果协程阻塞，整个线程都会被阻塞。此外，协程也无法利用多核CPU的优势，除非结合线程池或其他并发机制。选择协程还是线程，取决于具体的应用场景。对于IO密集型任务，协程通常更合适；对于CPU密集型任务，线程可能更适合。

如何处理协程中的异常？如果协程抛出异常，会发生什么？

协程中的异常处理主要依赖于promise_type的unhandled_exception()方法。当协程抛出未捕获的异常时，该方法会被调用。你可以在该方法中记录异常、清理资源或执行其他操作。如果unhandled_exception()本身也抛出异常，程序将会终止。

为了确保程序的健壮性，建议在协程内部使用try-catch块捕获异常，并在unhandled_exception()中进行适当的处理。一个更完善的promise_type可能还需要提供一个return_exception()方法，用于将异常传递给调用者。

struct ReturnObjectWithException {
    struct promise_type {
        ReturnObjectWithException get_return_object() { return {}; }
        std::suspend_never initial_suspend() { return {}; }
        std::suspend_always final_suspend() noexcept { return {}; }
        void unhandled_exception() {
            exception_ptr = std::current_exception();
        }
        void return_void() {}
        std::exception_ptr exception_ptr;
    };
};

ReturnObjectWithException MyCoroutineWithException() {
    std::cout << "Coroutine started\n";
    throw std::runtime_error("Something went wrong!");
    co_return;
}

int main() {
    auto coro = MyCoroutineWithException();
    // 检查异常
    return 0;
}

登录后复制

如何使用`co_yield`实现一个简单的生成器？生成器在实际开发中有哪些应用场景？

co_yield 关键字用于在协程中生成一个值，并将协程暂停，直到下一个值被请求。这使得我们可以方便地实现生成器，例如生成斐波那契数列、读取大型文件等。

下面是一个生成斐波那契数列的简单例子：

#include <iostream>
#include <coroutine>

struct Generator {
    struct promise_type {
        int current_value;
        std::suspend_always yield_value(int value) {
            current_value = value;
            return {};
        }
        std::suspend_never initial_suspend() { return {}; }
        std::suspend_always final_suspend() noexcept { return {}; }
        Generator get_return_object() { return Generator{std::coroutine_handle<promise_type>::from_promise(*this)}; }
        void return_void() {}
        void unhandled_exception() {}
    };

    using handle_type = std::coroutine_handle<promise_type>;

    Generator(handle_type h) : handle(h) {}
    ~Generator() { if (handle) handle.destroy(); }

    bool next() { return handle && handle.resume(), !handle.done(); }
    int value() { return handle.promise().current_value; }

private:
    handle_type handle;
};


Generator fibonacci(int n) {
    int a = 0, b = 1;
    for (int i = 0; i < n; ++i) {
        co_yield a;
        int temp = a;
        a = b;
        b = temp + b;
    }
}

int main() {
    auto gen = fibonacci(10);
    while (gen.next()) {
        std::cout << gen.value() << " ";
    }
    std::cout << std::endl;
    return 0;
}

登录后复制

生成器在实际开发中有很多应用场景，例如：