https://github.com/tonbit/coroutine是一個精巧的C++非對稱協程庫。庫只有一個.h文件（<500行的代碼），使用時也僅需要include這個頭文件。但是在功能上，可以提供Linux/Macos/Windows平臺的幾個必備的協程API（命名空間coroutine）：

* 創建協程：routine_t ?create( std::function<void()> ?f );
* 銷毀協程：void ?destroy( routine_t ?id );
* 恢復協程：int ?resume( routine_t ?id );
* 放棄協程：void ?yield();
* 等待異步任務結果：TYPE ?await(TYPE(*f)());
* 獲取當前協程的ID：routine_t current();
* SPSC通道模板類：class Channel<T>：支持push()/pop()操作;

可以在?https://github.com/tonbit/coroutine?獲取項目源碼。

一個具體的例子如下，注釋中解釋了每個API的使用：

#include <iostream> #include <chrono> //只需下載include此文件 #include "coroutine.h"//SPSC通道，多個生產者或消費者，協程調度行為不好控制 coroutine::Channel<int> channel; string async_func() {std::this_thread::sleep_for(std::chrono::milliseconds(3000));return "21"; }void routine_func1() {//從通道中獲取消息，如果沒有消息會yieldint i = channel.pop();std::cout << i << std::endl;i = channel.pop();std::cout << i << std::endl; }void routine_func2(int i) {std::cout << "20" << std::endl;//放棄當前協程的執行，返回恢復點coroutine::yield();std::cout << "21" << std::endl;//異步執行任務，如果任務無法立即執行完畢，會yieldstring str = coroutine::await(async_func);std::cout << str << std::endl; }void thread_func() {//創建協稱，回調函數形式為：std::function<void()>coroutine::routine_t rt1 = coroutine::create(routine_func1);coroutine::routine_t rt2 = coroutine::create(std::bind(routine_func2, 2));std::cout << "00" << std::endl;//恢復rt1coroutine::resume(rt1);std::cout << "01" << std::endl;//恢復rt2coroutine::resume(rt2);std::cout << "02" << std::endl;//向通道推送消息channel.push(10);std::cout << "03" << std::endl;coroutine::resume(rt2);std::cout << "04" << std::endl;channel.push(11);std::cout << "05" << std::endl;//銷毀協程。//建議：協程在執行完畢后統一釋放，這樣協程棧空間中的對象能夠安全的被到釋放。coroutine::destroy(rt1);coroutine::destroy(rt2); }int main() {std::thread t1(thread_func);std::thread t2([](){//不支持跨線程的協程調度});t1.join();t2.join();return 0; }

?

程序執行結果為：

?

00
01
20
02
10
03
21
04
11
05

轉載自：https://my.oschina.net/attobit/blog/753962

總結

以上是生活随笔為你收集整理的C++协程库coroutine使用指南的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。