目錄

• 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) {//遍歷睡眠集合，將滿足條件的加入到readynty_coroutine *expired = NULL;while ((expired = sleep_tree_expired(sched)) != ) {TAILQ_ADD(&sched->ready, expired);}//遍歷等待集合，將滿足添加的加入到readynty_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: 1989wangbojing@163.com
email: lizhiyong4360@gmail.com
email: 592407834@qq.com
協程技術交流群：829348971

轉載于:https://blog.51cto.com/240630/2306855

創作挑戰賽新人創作獎勵來咯，堅持創作打卡瓜分現金大獎

總結

以上是生活随笔為你收集整理的Linux高性能网络：协程系列08-协程实现之调度器的全部內容，希望文章能夠幫你解決所遇到的問題。

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