C语言中实现协程案例

协程是一种用户空间的非抢占式线程，主要用来解决等待大量的IO操作的问题。

协程vs线程

对比使用多线程来解决IO阻塞任务，使用协程的好处是不用加锁，访问共享的数据不用进行同步操作。这里需要说明的一点是，使用协程之所以不需要加锁不是因为所有的协程只在一个线程中运行，而是因为协程的非抢占式的特点。也就是说，使用协程的话，在没主动交出CPU之前都是不会被突然切换到其它协程上的。而线程是抢占式的，使用多线程你是不能确定你的线程什么时候被操作系统调度，什么时候被切换，因此需要用锁到实现一种“原子操作”的语义。

协程vs异步回调

其实更一般更常见的做法是，使用非阻塞的IO（比如是异步IO，又或者是在syscall上自己实现的一套异步IO，如asio）并且将处理操作写在回调函数中。这样的做法一般没什么问题，但当回调函数变多，一段连贯的业务代码就会被拆分到多个回调函数之中，增加维护的成本。因此使用协程可以用同步的写法写出效果相当于是异步的代码。

利用static变量实现协程

要实现一个协程，主要的问题是如何保存函数调用的上下文。之前在网上看到一篇博客coroutines in c，用一种非常简洁的方式实现了这个保存上下文的功能。实现代码如下：

#define crBegin static int _cr_state = 0; switch(_cr_state) { case 0:
#define crReturn(x) do { _cr_state = __LINE__; return x; case __LINE__:; } while (0)
#define crFinish }

int func1() {
    crBegin
    while (1)
    {
        printf("hello world\n");
        crReturn(0);
    }
    crFinish
}

这个代码利用了函数的static变量来保存函数调用状态。注意，由于vs2013有一个调试特性，所以vs2013的__LINE__的实现不是常量因此会编译不通过，使用gcc就可以编译。这段代码简单是简单但是有问题，比如说如果两个协程调用同一个函数，就会出错。因此博客里面提及这段代码主要是给出一个思路，如果实际使用的话这样子肯定是不行的。

利用setjmp、longjmp实现协程

前面说过，实现协程最主要的是保存函数的调用的上下文，而这些上下文主要就两个部分：1.各个寄存器的值，2.函数调用栈。C语言里可以通过setjmp来保存函数调用时，各寄存器的值。保存之后，便可以通过longjmp重现回到当初setjmp的地方（可以理解成跨函数的goto）。但是，需要注意的是，setjmp仅负责保存寄存器的值，不负责维护其函数调用栈（这个看看setjmp的jmp_buf的结构就知道了），因此必须由使用者来手动的维护这个函数调用栈。使用setjmp、longjmp的一个常见的错误就是，尝试去longjmp到一个已经执行完的函数，这时候虽然寄存器的值是当时保存的值，但是调用栈已经不是原来的调用栈了。

而我的做法是，在创建一个协程的时候在堆上申请一块空间（大小为2M）作为协程的调用栈，然后在setjmp的时候，手动更改寄存器esp的值，使其指向这个我自己创建的调用栈。因此在以后运行的时候，这个协程就会使用我提供的那块内存作为栈。

我的这个协程库提供了三个接口：

  1. coro_new：创建一个协程
  2. coro_yield：将控制权返回给调度协程
  3. coro_main：运行调度协程

协程的控制流程如下：

  1. 通过coro_main运行调度协程，并找出下一个运行的协程，运行之。
  2. 运行这个协程直到其调用coro_yield将控制权返还给调度协程。
  3. 重复以上两个步骤，直到所有协程运行完毕。

这个协程库实现的非常简单，只有100来行的代码，当然实现它的目的是为了提供一个最简单的协程模型，而不是一个功能完整、鲁棒性强的能投入实际业务运行的协程。

因此问题还是有很多的：

  1. 比如当在协程里面调用栈超过2M时，这个是需要处理的，现在的代码是没有做的，理应中断程序，避免写坏堆，产生随机的不可重现的问题。
  2. 显然在实现时没有考虑到多线程，如果在多线程环境里面运行，需要代码做同步处理。
  3. 现在的这个版本的协程有一个约定，在协程里调用的函数不能阻塞在syscall，这显然也是不科学的。一个完整的协程库，应该包含一些常用的syscall的非阻塞的实现，毕竟只有一个线程不能真的阻塞在这个调用上。

总结

当然实现协程还有比较一些更好的方法，比如如果能用glibc的ucontext库就可以基于这个库来实现，而不用自己手动管理函数调用的上下文了，如云风实现的协程库。

到此这篇关于C语言中实现协程案例的文章就介绍到这了,更多相关C语言实现协程内容请搜索我们以前的文章或继续浏览下面的相关文章希望大家以后多多支持我们！

赞 (0)

相关推荐

  • C语言实现三子棋游戏附注释

    C语言实现三子棋游戏附注释

    本文实例为大家分享了C语言实现三子棋游戏的具体代码,供大家参考,具体内容如下 概述 三子棋棋盘为九宫格形式,玩家和电脑分别轮流落子,若有一方有三个棋连在一起的情况则胜. 实现过程 1.玩家交互菜单创建 2.棋盘创建与初始化 3.玩家与电脑落子 4.判定胜负关系 多文件实现 头文件 game.h #ifndef __GAME_H__ #define __GAME_H__ #include <stdio.h> #include <time.h> #include <stdlib.

  • 详解C语言之缓冲区溢出

    详解C语言之缓冲区溢出

    一.缓冲区溢出原理 栈帧结构的引入为高级语言中实现函数或过程调用提供直接的硬件支持,但由于将函数返回地址这样的重要数据保存在程序员可见的堆栈中,因此也给系统安全带来隐患.若将函数返回地址修改为指向一段精心安排的恶意代码,则可达到危害系统安全的目的.此外,堆栈的正确恢复依赖于压栈的EBP值的正确性,但EBP域邻近局部变量,若编程中有意无意地通过局部变量的地址偏移窜改EBP值,则程序的行为将变得非常危险. 由于C/C++语言没有数组越界检查机制,当向局部数组缓冲区里写入的数据超过为其分配的大小时,就

  • C语言char s[]和char* s的区别

    C语言char s[]和char* s的区别

    C语言指针可以代替数组使用 1.数组本质 数组是多个元素的集合,在内存中分布在地址连续的单元中,因此可以通过其下标访问数组的不同数组. 例如: 下面展示一些 char s[3] = "0x1"; printf("s2字符串:\n"); printf("%c\n", s[0]); printf("%c\n", s[1]); printf("%c\n", s[2]); 2.指针 指针也是一种变量,只不过它的内存

  • 使用C语言操作树莓派GPIO的详细步骤

    使用C语言操作树莓派GPIO的详细步骤

    第一步安装GPIO库. cd /tmp wget https://project-downloads.drogon.net/wiringpi-latest.deb sudo dpkg -i wiringpi-latest.deb 地址链接4B的 http://wiringpi.com/wiringpi-updated-to-2-52-for-the-raspberry-pi-4b/ 第二步打开GPIO设置 打开GPIO,学习嘛,全打开得了. 保存重启. 第三步找一个GPIO的图 然后找一张树莓派

  • C语言指针详解

    前言:复杂类型说明     要了解指针,多多少少会出现一些比较复杂的类型,所以我先介绍一下如何完全理解一个复杂类型,要理解复杂类型其实很简单,一个类型里会出现很多运算符,他们也像普通的表达式一样,有优先级,其优先级和运算优先级一样,所以我总结了一下其原则:从变量名处起,根据运算符优先级结合,一步一步分析.下面让我们先从简单的类型开始慢慢分析吧: int p; //这是一个普通的整型变量   int *p; //首先从P 处开始,先与*结合,所以说明P 是一个指针,然后再与int 结合,说明指针所

  • C语言指针数组案例详解

    指针与数组是 C 语言中很重要的两个概念,它们之间有着密切的关系,利用这种 关系,可以增强处理数组的灵活性,加快运行速度,本文着重讨论指针与数组之 间的联系及在编程中的应用. 1．指针与数组的关系 当一个指针变量被初始化成数组名时,就说该指针变量指向了数组.如: char str[20], *ptr; ptr=str; ptr 被置为数组 str 的第一个元素的地址,因为数组名就是该数组的首地址, 也是数组第一个元素的地址.此时可以认为指针 ptr 就是数组 str(反之不成立), 这样原来对数

  • C语言实现三子棋小游戏（vs2013多文件）

    本文通过实例为大家分享了C语言实现三子棋小游戏的具体代码,供大家参考,具体内容如下 基本思路: 1.创建一个游戏选择面板. 2.创建并初始化棋盘. 3.玩家落子并判定,电脑落子并判定. 4.判定结果 ,游戏结束! 代码如下: 头文件: #pragma once #include<stdio.h> #include<windows.h> #include<stdlib.h> #include <time.h> #pragma warning(disable:4

  • C语言中实现协程案例

    协程是一种用户空间的非抢占式线程,主要用来解决等待大量的IO操作的问题. 协程vs线程 对比使用多线程来解决IO阻塞任务,使用协程的好处是不用加锁,访问共享的数据不用进行同步操作.这里需要说明的一点是,使用协程之所以不需要加锁不是因为所有的协程只在一个线程中运行,而是因为协程的非抢占式的特点.也就是说,使用协程的话,在没主动交出CPU之前都是不会被突然切换到其它协程上的.而线程是抢占式的,使用多线程你是不能确定你的线程什么时候被操作系统调度,什么时候被切换,因此需要用锁到实现一种"原子操作&qu

  • go语言中的协程详解

    go语言中的协程详解

    协程的特点 1.该任务的业务代码主动要求切换,即主动让出执行权限 2.发生了IO,导致执行阻塞(使用channel让协程阻塞) 与线程本质的不同 C#.java中我们执行多个线程,是通过时间片切换来进行的,要知道进行切换,程序需要保存上下文等信息,是比较消耗性能的 GO语言中的协程,没有上面这种切换,一定是通过协程主动放出权限,不是被动的. 例如: C# 中创建两个线程 可以看到1和2是交替执行的 Go语言中用协程实现一下 runtime.GOMAXPROCS(1) 这个结果就是 执行了1 在执

  • python3爬虫中异步协程的用法

    1. 前言 在执行一些 IO 密集型任务的时候,程序常常会因为等待 IO 而阻塞.比如在网络爬虫中,如果我们使用 requests 库来进行请求的话,如果网站响应速度过慢,程序一直在等待网站响应,最后导致其爬取效率是非常非常低的. 为了解决这类问题,本文就来探讨一下 Python 中异步协程来加速的方法,此种方法对于 IO 密集型任务非常有效.如将其应用到网络爬虫中,爬取效率甚至可以成百倍地提升. 注:本文协程使用 async/await 来实现,需要 Python 3.5 及以上版本. 2.

  • C++20中的协程(Coroutine)的实现

    C++20中的协程(Coroutine) 从2017年开始, 协程(Coroutine)的概念就开始被建议加入C++20的标准中了,并已经开始有人对C++20协程的提案进行了介绍.1事实上,协程的概念在很早就出现了,甚至其他语言(JS,Python,C#等)早就已经支持了协程. 可见,协程并不是C++所特有的概念. 那么,什么是协程? 简单来说,协程就是一种特殊的函数,它可以在函数执行到某个地方的时候暂停执行,返回给调用者或恢复者(可以有一个返回值),并允许随后从暂停的地方恢复继续执行.注意,这

  • java协程框架quasar和kotlin中的协程对比分析

    java协程框架quasar和kotlin中的协程对比分析

    目录 前言 快速体验 添加依赖 添加javaagent 线程VS协程 协程代码 多线程代码 协程完胜 后记 前言 早就听说Go语言开发的服务不用任何架构优化,就可以轻松实现百万级别的qps.这得益于Go语言级别的协程的处理效率.协程不同于线程,线程是操作系统级别的资源,创建线程,调度线程,销毁线程都是重量级别的操作.而且线程的资源有限,在java中大量的不加限制的创建线程非常容易将系统搞垮.接下来要分享的这个开源项目,正是解决了在java中只能使用多线程模型开发高并发应用的窘境,使得java也能

  • 在Python 的线程中运行协程的方法

    在一篇文章 理解Python异步编程的基本原理 这篇文章中,我们讲到,如果在异步代码里面又包含了一段非常耗时的同步代码,异步代码就会被卡住. 那么有没有办法让同步代码与异步代码看起来也是同时运行的呢?方法就是使用事件循环的.run_in_executor()方法. 我们来看一下 Python 官方文档[1]中的说法: 那么怎么使用呢?还是以非常耗时的递归方式计算斐波那契数列的这个函数为例: def sync_calc_fib(n): if n in [1, 2]: return1 return

  • C语言中操作sqlserver数据库案例教程

    C语言中操作sqlserver数据库案例教程

    本文使用c语言来对sql server数据库进行操作,实现通过程序来对数据库进行增删改查操作. 操作系统:windows 10         实验平台:vs2012  +  sql server 2008 ODBC简介:开放数据库连接(Open Database Connectivity,ODBC),主要的功能是提供了一组用于数据库访问的编程接口,其主要的特点是,如果应用程序使用ODBC做数据源,那么这个应用程序与所使用的数据库或数据库引擎是无关的,为应用程序的跨平台和可移植奠定了基础. 创建

  • 浅谈golang for 循环中使用协程的问题

    两个例子 package main import ( "fmt" "time" ) func Process1(tasks []string) { for _, task := range tasks { // 启动协程并发处理任务 go func() { fmt.Printf("Worker start process task: %s\n", task) }() } } func main() { tasks := []string{&quo

  • 简单介绍Python的Tornado框架中的协程异步实现原理

    Tornado 4.0 已经发布了很长一段时间了, 新版本广泛的应用了协程(Future)特性. 我们目前已经将 Tornado 升级到最新版本, 而且也大量的使用协程特性. 很长时间没有更新博客, 今天就简单介绍下 Tornado 协程实现原理, Tornado 的协程是基于 Python 的生成器实现的, 所以首先来回顾下生成器. 生成器 Python 的生成器可以保存执行状态 并在下次调用的时候恢复, 通过在函数体内使用 yield 关键字 来创建一个生成器, 通过内置函数 next 或生

  • python中的协程深入理解

    python中的协程深入理解

    先介绍下什么是协程: 协程,又称微线程,纤程,英文名Coroutine.协程的作用,是在执行函数A时,可以随时中断,去执行函数B,然后中断继续执行函数A(可以自由切换).但这一过程并不是函数调用(没有调用语句),这一整个过程看似像多线程,然而协程只有一个线程执行. 是不是有点没看懂,没事,我们下面会解释.要理解协程是什么,首先需要理解yield,这里简单介绍下,yield可以理解为生成器,yield item这行代码会产出一个值,提供给next(...)的调用方; 此外,还会作出让步,暂停执行生

随机推荐