libgo 协程库使用教程

项目介绍

libgo 是一个使用 C++11 编写的协作式调度的 stackful 协程库，同时也是一个强大的并行编程库。它专为 Linux 服务端程序开发设计，支持 Linux、Windows 和 Mac 平台。libgo 提供了类似于 Go 语言的协程功能，允许用户以同步的方式编写代码，同时获得异步的性能。它支持海量协程、用户自由控制协程调度点、多线程调度协程等特性，使得并行编程变得简单高效。

项目快速启动

安装 libgo

使用 vcpkg 安装

如果你已经安装了 vcpkg，可以直接使用以下命令安装 libgo：

vcpkg install libgo

在 Linux 上编译安装

1. 使用 cmake 编译和安装：

mkdir build
cd build
cmake ..
make
sudo make install

2. 动态链接 glibc：

g++ -std=c++11 test.cpp -llibgo -ldl [-lother_libs]

3. 全静态链接：

g++ -std=c++11 test.cpp -llibgo -Wl,--whole-archive -lstatic_hook -lc -lpthread -Wl,--no-whole-archive [-lother_libs] -static

编写第一个协程程序

以下是一个简单的示例代码，展示了如何使用 libgo 创建和运行协程：

#include <libgo/coroutine.h>
#include <iostream>

void foo() {
    std::cout << "Hello, libgo!" << std::endl;
}

int main() {
    go foo; // 创建并运行协程
    co_sched.Start(); // 启动调度器
    return 0;
}

编译并运行这个程序：

g++ -std=c++11 test.cpp -llibgo -ldl
./a.out

应用案例和最佳实践

并发网络服务器

libgo 非常适合用于编写并发网络服务器。以下是一个简单的 TCP 服务器示例：

#include <libgo/coroutine.h>
#include <libgo/net.h>
#include <iostream>

void handle_client(co_socket client_socket) {
    char buffer[1024];
    int n = client_socket.recv(buffer, sizeof(buffer));
    if (n > 0) {
        std::cout << "Received: " << std::string(buffer, n) << std::endl;
        client_socket.send(buffer, n);
    }
}

int main() {
    co_socket server_socket;
    server_socket.bind("0.0.0.0", 8080);
    server_socket.listen(10);

    while (true) {
        co_socket client_socket = server_socket.accept();
        go [client_socket] { handle_client(client_socket); };
    }

    co_sched.Start();
    return 0;
}

并行任务处理

libgo 可以轻松实现并行任务处理。以下是一个并行计算示例：

#include <libgo/coroutine.h>
#include <iostream>
#include <vector>

void task(int id) {
    std::cout << "Task " << id << " is running" << std::endl;
}

int main() {
    std::vector<int> tasks = {1, 2, 3, 4, 5};
    for (int id : tasks) {
        go [id] { task(id); };
    }
    co_sched.Start();
    return 0;
}

典型生态项目

与 hiredis 结合使用

libgo 可以让同步的第三方库变为异步调用，例如 hiredis（Redis 的 C 客户端库）：

#include <libgo/coroutine.h>
#include <hiredis/hiredis.h>
#include <iostream>

void redis_task() {