目录

• Linux高性能网络：协程系列01-前言
• Linux高性能网络：协程系列02-协程的起源
• Linux高性能网络：协程系列03-协程的案例
• Linux高性能网络：协程系列04-协程实现之工作原理
• Linux高性能网络：协程系列05-协程实现之原语操作
• Linux高性能网络：协程系列06-协程实现之切换
• Linux高性能网络：协程系列07-协程实现之定义
• Linux高性能网络：协程系列08-协程实现之调度器
• Linux高性能网络：协程系列09-协程性能测试
• [Linux高性能网络：协程系列10 待续]()

8.协程实现之调度器

• 8.0 前言
• 8.1生产者消费者模式
• 8.2 多状态下运行

8.0 前言

  问题：协程如何被调度？

  调度器的实现，有两种方案，一种是生产者消费者模式，另一种多状态运行。

8.1 生产者消费者模式

  逻辑代码如下：

while (1) {

        //遍历睡眠集合，将满足条件的加入到ready
        nty_coroutine *expired = NULL;
        while ((expired = sleep_tree_expired(sched)) != ) {
            TAILQ_ADD(&sched->ready, expired);
        }

        //遍历等待集合，将满足添加的加入到ready
        nty_coroutine *wait = NULL;
        int nready = epoll_wait(sched->epfd, events, EVENT_MAX, 1);
        for (i = 0;i < nready;i ++) {
            wait = wait_tree_search(events[i].data.fd);
            TAILQ_ADD(&sched->ready, wait);
        }

        // 使用resume回复ready的协程运行权
        while (!TAILQ_EMPTY(&sched->ready)) {
            nty_coroutine *ready = TAILQ_POP(sched->ready);
            resume(ready);
        }
    }

8.2 多状态下运行

  逻辑代码如下：

while (1) {

        //遍历睡眠集合，使用resume恢复expired的协程运行权
        nty_coroutine *expired = NULL;
        while ((expired = sleep_tree_expired(sched)) != ) {
            resume(expired);
        }

        //遍历等待集合，使用resume恢复wait的协程运行权
        nty_coroutine *wait = NULL;
        int nready = epoll_wait(sched->epfd, events, EVENT_MAX, 1);
        for (i = 0;i < nready;i ++) {
            wait = wait_tree_search(events[i].data.fd);
            resume(wait);
        }

        // 使用resume恢复ready的协程运行权
        while (!TAILQ_EMPTY(sched->ready)) {
            nty_coroutine *ready = TAILQ_POP(sched->ready);
            resume(ready);
        }
    }

更多分享

email: [email protected]
email: [email protected]
email: [email protected]
协程技术交流群：829348971

原文地址：http://blog.51cto.com/240630/2306855