PHP協(xié)程

SolomonXie 發(fā)布于2019-07-01 10:33 / 2669人閱讀

摘要：協(xié)程協(xié)程就是用戶態(tài)的線程要理解是什么是用戶態(tài)的線程，必然就要先理解什么是內(nèi)核態(tài)的線程。記住，不是協(xié)程，而是協(xié)程需要借助的特性來(lái)實(shí)現(xiàn)。

協(xié)程

“協(xié)程”就是用戶態(tài)的線程
要理解是什么是“用戶態(tài)的線程”，必然就要先理解什么是“內(nèi)核態(tài)的線程”。 內(nèi)核態(tài)的線程是由操作系統(tǒng)來(lái)進(jìn)行調(diào)度的，在切換線程上下文時(shí)，要先保存上一個(gè)線程的上下文，然后執(zhí)行下一個(gè)線程，當(dāng)條件滿足時(shí)，切換回上一個(gè)線程，并恢復(fù)上下文。 協(xié)程也是如此，只不過(guò)，用戶態(tài)的線程不是由操作系統(tǒng)來(lái)調(diào)度的，而是由程序員來(lái)調(diào)度的，是在用戶態(tài)的 -- 摘自鏈接描述

關(guān)于“用戶態(tài)線程”，我們用個(gè)小例子來(lái)加深理解

我們有兩個(gè)函數(shù) task1,task2，我們來(lái)手動(dòng)調(diào)度它們的執(zhí)行順序，比如在task1執(zhí)行一半的時(shí)候去執(zhí)行task2，兩個(gè)或者多個(gè)函數(shù)之間交替執(zhí)行（這就是協(xié)程的概念）。

我們來(lái)個(gè)正常的函數(shù)調(diào)用方式：


可想而知，以上的輸出肯定是：
task1函數(shù) 執(zhí)行第1
task1函數(shù) 執(zhí)行第2
task2函數(shù) 執(zhí)行第1
task2函數(shù) 執(zhí)行第2
但是我想在程序輸出task1函數(shù) 執(zhí)行1之后就輸出task2函數(shù) 執(zhí)行1怎么辦？
這個(gè)時(shí)候 yield 就派上用場(chǎng)了，PHP里的協(xié)程是需要借助 yield 來(lái)完成的。記住，yield 不是協(xié)程，而是協(xié)程需要借助 yield 的特性來(lái)實(shí)現(xiàn)。
current();
$task2->current();
以上輸出：
task1函數(shù) 執(zhí)行1
task2函數(shù) 執(zhí)行1
很好，以上結(jié)果達(dá)到了我們的預(yù)期。但是怎么讓函數(shù)里的代碼往下執(zhí)行呢？
調(diào)用生成器的next方法：
$task1->next();
$task2->next();
最后你將看到的輸出結(jié)果是兩個(gè)函數(shù)交替執(zhí)行輸出的：
task1函數(shù) 執(zhí)行1
task2函數(shù) 執(zhí)行1
task1函數(shù) 執(zhí)行2
task2函數(shù) 執(zhí)行2
小段總結(jié)
以上的代碼實(shí)現(xiàn)可以抽象出兩個(gè)概念，任務(wù)和調(diào)度，任務(wù)就是task函數(shù)，調(diào)度就是我們?cè)趺慈フ{(diào)用這些task函數(shù)
調(diào)度器和任務(wù)生成器
上一個(gè)小段總結(jié)里有兩個(gè)概念叫任務(wù)和調(diào)度，我們簡(jiǎn)單的封裝個(gè)任務(wù)生成器和調(diào)度器
// 任務(wù)生成器
$createTask = (function () {
    $tasks = [];
    return function ($callback) use (&$tasks) {
        $task = [
            "task" => $callback(),
            "id" => count($tasks) + 1,
        ];
        array_push($tasks, $task);
        return $task;
    };
})();

// 調(diào)度器
function schedule($tasks)
{
    $first = [];
    while (!empty($tasks)) {
        $task = array_shift($tasks);
        if (!array_key_exists($task["id"], $first)) {
            $first[$task["id"]] = true;
            $task["task"]->current();
        } else {
            $task["task"]->next();
        }
        if (!$task["task"]->valid()) {
            unset($tasks[$k]);
        } else {
            array_push($tasks, $task);
        }
    }
}

使用
$tasks = [
    $createTask(function () {
        echo "任務(wù)1 執(zhí)行第1次
";
        yield;
        echo "任務(wù)1 執(zhí)行第2次
";
    }),
    $createTask(function () {
        echo "任務(wù)2 執(zhí)行第1次
";
        yield;
        echo "任務(wù)2 執(zhí)行第2次
";
    })
];

schedule($tasks);
輸出結(jié)果：
任務(wù)1 執(zhí)行第1次
任務(wù)2 執(zhí)行第1次
任務(wù)1 執(zhí)行第2次
任務(wù)2 執(zhí)行第2次
可以從結(jié)果看出，調(diào)度器已經(jīng)實(shí)現(xiàn)了多個(gè)任務(wù)之間進(jìn)行協(xié)作。
網(wǎng)絡(luò)請(qǐng)求
現(xiàn)在有個(gè)需求！就是任務(wù)在遇到網(wǎng)絡(luò)請(qǐng)求的時(shí)候，我們無(wú)需等待網(wǎng)絡(luò)請(qǐng)求的響應(yīng)結(jié)果，而是遇到網(wǎng)絡(luò)請(qǐng)求的時(shí)候，把這個(gè)任務(wù)掛起，然后去執(zhí)行其它任務(wù)，等網(wǎng)絡(luò)請(qǐng)求收到響應(yīng)結(jié)果了再通知我們處理
這時(shí)候需要我們用到非阻塞IO調(diào)用相關(guān)技術(shù)，涉及到系統(tǒng)內(nèi)核層面，想了解可以點(diǎn)擊鏈接描述
在PHP里我們需要安裝個(gè)擴(kuò)展eio，大家自行安裝
pecl install eio
編碼：
$tasks = [
    $createTask(function () {
        echo "任務(wù)1 執(zhí)行第1次
";
        yield;
        echo "任務(wù)1 執(zhí)行第2次
";
    }),
    $createTask(function () {
        echo "任務(wù)2 執(zhí)行第1次
";

        eio_custom(function () {
            return file_get_contents("https://segmentfault.com/");
        }, EIO_PRI_DEFAULT, function ($data, $ret) {
            echo "請(qǐng)求完成
";
        });
        
        yield;

        echo "任務(wù)2 執(zhí)行第2次
";
    })
];

schedule($tasks);

eio_event_loop();
在任務(wù)2 執(zhí)行第1次的時(shí)候，遇到網(wǎng)絡(luò)請(qǐng)求，我們把請(qǐng)求任務(wù)交給系統(tǒng)內(nèi)核，然后切換到其它任務(wù)去，等請(qǐng)求任務(wù)完成后回調(diào)我們傳入的函數(shù)。
輸出結(jié)果：
任務(wù)1 執(zhí)行第1次
任務(wù)2 執(zhí)行第1次
任務(wù)1 執(zhí)行第2次
任務(wù)2 執(zhí)行第2次
任務(wù)2 執(zhí)行第1次的請(qǐng)求完成
完！