關(guān)于PHP協(xié)程與阻塞的思考

FullStackDeveloper 發(fā)布于2019-06-28 13:22 / 3158人閱讀

摘要：線程擁有自己獨(dú)立的棧和共享的堆，共享堆，不共享?xiàng)?，線程亦由操作系統(tǒng)調(diào)度標(biāo)準(zhǔn)線程是的。以及鳥哥翻譯的這篇詳細(xì)文檔我就以他實(shí)現(xiàn)的協(xié)程多任務(wù)調(diào)度為基礎(chǔ)做一下例子說明并說一下關(guān)于我在阻塞方面所做的一些思考。

進(jìn)程、線程、協(xié)程

關(guān)于進(jìn)程、線程、協(xié)程，有非常詳細(xì)和豐富的博客或者學(xué)習(xí)資源，我不在此做贅述，我大致在此介紹一下這幾個(gè)東西。

進(jìn)程擁有自己獨(dú)立的堆和棧，既不共享堆，亦不共享?xiàng)?，進(jìn)程由操作系統(tǒng)調(diào)度。

線程擁有自己獨(dú)立的棧和共享的堆，共享堆，不共享?xiàng)?，線程亦由操作系統(tǒng)調(diào)度(標(biāo)準(zhǔn)線程是的)。

協(xié)程和線程一樣共享堆，不共享?xiàng)?，協(xié)程由程序員在協(xié)程的代碼里顯示調(diào)度。

PHP中的協(xié)程實(shí)現(xiàn)基礎(chǔ) yield

yield的根本實(shí)現(xiàn)是生成器類，而迭代器類是迭代器接口的實(shí)現(xiàn)：

Generator?implements?Iterator?{
    public?mixed?current?(?void?) // 返回當(dāng)前產(chǎn)生的值
    public?mixed?key?(?void?) // 返回當(dāng)前產(chǎn)生的鍵
    public?void?next?(?void?) // 生成器繼續(xù)執(zhí)行
    public?void?rewind?(?void?) // 重置迭代器，如果迭代已經(jīng)開始了，這里會(huì)拋出一個(gè)異常。
                                             // renwind的執(zhí)行將會(huì)導(dǎo)致第一個(gè)yield被執(zhí)行, 并且忽略了他的返回值.
    public?mixed?send?(?mixed?$value?) // 向生成器中傳入一個(gè)值，并且當(dāng)做?yield?表達(dá)式的結(jié)果，然后繼續(xù)執(zhí)行生成器。如果當(dāng)這個(gè)方法被調(diào)用時(shí)，生成器   
                                            // 不在?yield?表達(dá)式，那么在傳入值之前，它會(huì)先運(yùn)行到第一個(gè)?yield?表達(dá)式。
    public?void?throw?(?Exception?$exception?) // 向生成器中拋入一個(gè)異常
    public?bool?valid?(?void?) // 檢查迭代器是否被關(guān)閉
    public?void?__wakeup?(?void?) // 序列化回調(diào)，拋出一個(gè)異常以表示生成器不能被序列化。
}

以上解析可以參考PHP官方文檔。

http://php.net/manual/zh/clas...

以及鳥哥翻譯的這篇詳細(xì)文檔：

http://www.laruence.com/2015/...

我就以他實(shí)現(xiàn)的協(xié)程多任務(wù)調(diào)度為基礎(chǔ)做一下例子說明并說一下關(guān)于我在阻塞方面所做的一些思考。

自定義簡(jiǎn)單定時(shí)執(zhí)行任務(wù)示例：

(此例子必須依賴于以上鳥哥實(shí)現(xiàn)的協(xié)程調(diào)度代碼)


class timer {
    private $start = 0; // 定時(shí)開始時(shí)間
    private $timer; // 間隔的時(shí)間差，單位秒
    private $value = 0; // 產(chǎn)生的結(jié)果值
    private $callback; // 異步回調(diào)
    private $isEnd = false; // 當(dāng)前定時(shí)器任務(wù)是否結(jié)束
    public function __construct($timer,callable $callback)
    {
        $this->start = time();
        $this->timer = $timer;
        $this->callback = $callback;
    }
    public function run() {
        if($this->valid()) {
            $callback = $this->callback;
            $callback($this->value ++,$this);
            $this->start = time();
        }
    }
    /**
     * 定時(shí)執(zhí)行檢查
     */
    public function valid() {
        $end = time();
        if($end - $this->start >= $this->timer) {
            return true;
        } else {
            return false;
        }
    }
    public function setEnd($isEnd) {
        $this->isEnd = $isEnd;
    }
    public function getEnd() {
        return $this->isEnd;
    }
}

/**
 * 模擬阻塞的協(xié)程1
 *
 */
function taskObject1() {
    $timer = new timer(1,function($value,timer $timer) {
        if($value >= 5) {
            $timer->setEnd(true);
        }
        echo "
"."A ".$value;
    });
    $tid = (yield getTaskId());
    while (true) {
        if($timer->getEnd() == true) {
            break;
        }
        yield $timer->run();
    }
}
/**
 * 模擬阻塞的協(xié)程2
 *
 */
function taskObject2() {
    $timer = new timer(2,function($value,timer $timer) {
        if($value >= 3) {
            $timer->setEnd(true);
        }
        echo "
"."B ".$value;
    });
    $tid = (yield getTaskId());
    while (true) {
        if($timer->getEnd() == true) {
            break;
        }
        yield $timer->run();
    }
}
$scheduler = new Scheduler;
$scheduler->newTask(taskObject1());
$scheduler->newTask(taskObject2());
$scheduler->run();

以上實(shí)現(xiàn)的是：

產(chǎn)生兩個(gè)任務(wù)，并行執(zhí)行，并且給每個(gè)任務(wù)在執(zhí)行的時(shí)候模擬幾秒鐘的阻塞；

讓協(xié)程切換的時(shí)候能順利切換，其中的任務(wù)阻塞不相互影響；

思考：

我為什么要做以上這件事情呢？因?yàn)槲野l(fā)現(xiàn)協(xié)程實(shí)現(xiàn)雖然很強(qiáng)大也很有意思，能讓多任務(wù)并行，但是我在其中一個(gè)任務(wù)里調(diào)用系統(tǒng)函數(shù) sleep() 的時(shí)候,阻塞任務(wù)會(huì)阻止協(xié)程切換，其實(shí)從協(xié)程的實(shí)現(xiàn)原理上來說也是這么回事。

那么，我也就想模擬協(xié)程阻塞，但是不產(chǎn)生阻塞看是否可行。PHP本身只提供了生成器為協(xié)程調(diào)用提供了支撐，如果不依賴擴(kuò)展，沒有提供多線程的程序?qū)崿F(xiàn)方式，沒有java那么強(qiáng)大，可以開子線程進(jìn)行實(shí)現(xiàn)。

我印象中java的子線程是獨(dú)立執(zhí)行且不會(huì)相互阻塞的，所以我在想，PHP既然可以實(shí)現(xiàn)類似于多線程這樣的機(jī)制，那么能不能實(shí)現(xiàn)調(diào)用過程中非阻塞呢？

經(jīng)過這樣一個(gè)實(shí)現(xiàn)和思考，一開始是陷入了一個(gè)誤區(qū)的，是由于PHP原生函數(shù) sleep() 阻塞造成的思維誤區(qū)，那就是認(rèn)為要想真正實(shí)現(xiàn)非阻塞或者說實(shí)現(xiàn)異步的話，是必須依賴于語言底層的。

后來，我想明白了一個(gè)道理，既然某個(gè)方法或者函數(shù)在執(zhí)行過程中，會(huì)產(chǎn)生阻塞，那么把當(dāng)前這個(gè)方法換成自定義的，做成非阻塞（相對(duì)于整個(gè)協(xié)程調(diào)度來說）不就行了嗎？比如上面的定時(shí)執(zhí)行我自己實(shí)現(xiàn)了一個(gè)。

而另一方面，協(xié)程調(diào)度本身的目的也是為了把任務(wù)執(zhí)行過程切成盡量小片，從而快速切換執(zhí)行，達(dá)到并行的目的。從這方面來看，協(xié)程應(yīng)該也算是一種程序設(shè)計(jì)思想。

以下是一個(gè)程序切成盡量小片執(zhí)行的例子：

// 一個(gè)簡(jiǎn)單的例子

這個(gè)例子是把原本用 range 生成一個(gè)很大的整型數(shù)組的方式切換為分片執(zhí)行，也就是說在遍歷的時(shí)候再去取到指定的值，從代碼上來看，內(nèi)存消耗相對(duì)于之前來說就非常小了。

文章版權(quán)歸作者所有，未經(jīng)允許請(qǐng)勿轉(zhuǎn)載,若此文章存在違規(guī)行為，您可以聯(lián)系管理員刪除。

轉(zhuǎn)載請(qǐng)注明本文地址：http://systransis.cn/yun/25603.html

發(fā)表評(píng)論

登陸后可評(píng)論

0條評(píng)論

FullStackDeveloper

男|高級(jí)講師

我要關(guān)注我要私信

TA的文章

虛擬主機(jī)用用什么管理平臺(tái)-虛擬主機(jī)管理系統(tǒng)有什么用？

閱讀 1123·2021-09-22 16:04
純CSS實(shí)現(xiàn)垂直居中的幾種方法

閱讀 1502·2019-08-30 15:43
CSS簡(jiǎn)潔筆記

閱讀 1110·2019-08-29 14:01
初識(shí)React(3)：組件

閱讀 3446·2019-08-26 12:19
【JavaScript】Promise

閱讀 3361·2019-08-26 12:15
JS面試?yán)碚擃}

閱讀 1454·2019-08-26 12:13
瀏覽器渲染機(jī)制

閱讀 3273·2019-08-23 17:00
每日 30 秒 ? 數(shù)組所有數(shù)據(jù)是否滿足某條件

閱讀 1491·2019-08-23 15:38

成人国产在线小视频_日韩寡妇人妻调教在线播放_色成人www永久在线观看_2018国产精品久久_亚洲欧美高清在线30p_亚洲少妇综合一区_黄色在线播放国产_亚洲另类技巧小说校园_国产主播xx日韩_a级毛片在线免费

資訊專欄INFORMATION COLUMN

上云采購(gòu)季！| 2核2G4M爆款云服務(wù)器低至59元/年，更有多臺(tái)、長(zhǎng)期優(yōu)惠，快來選購(gòu)！

關(guān)于PHP協(xié)程與阻塞的思考

相關(guān)文章

python協(xié)程與golang協(xié)程的區(qū)別

**【宇潤(rùn)日常瘋測(cè)-007】Swoole 協(xié)程與傳統(tǒng) fpm 同步模式比較**

談?wù)凱ython協(xié)程技術(shù)的演進(jìn)

Python 學(xué)習(xí)筆記關(guān)于協(xié)程

**Python 中的進(jìn)程、線程、協(xié)程、同步、異步、回調(diào)**

發(fā)表評(píng)論

0條評(píng)論

FullStackDeveloper

男|高級(jí)講師

TA的文章

虛擬主機(jī)用用什么管理平臺(tái)-虛擬主機(jī)管理系統(tǒng)有什么用？

純CSS實(shí)現(xiàn)垂直居中的幾種方法

CSS簡(jiǎn)潔筆記

初識(shí)React(3)：組件

【JavaScript】Promise

JS面試?yán)碚擃}

瀏覽器渲染機(jī)制

每日 30 秒 ? 數(shù)組所有數(shù)據(jù)是否滿足某條件

最新活動(dòng)

資訊專欄INFORMATION COLUMN

上云采購(gòu)季！| 2核2G4M爆款云服務(wù)器低至59元/年，更有多臺(tái)、長(zhǎng)期優(yōu)惠，快來選購(gòu)！

關(guān)于PHP協(xié)程與阻塞的思考

相關(guān)文章

發(fā)表評(píng)論

0條評(píng)論

男|高級(jí)講師

TA的文章

最新活動(dòng)

上云采購(gòu)季！| 2核2G4M爆款云服務(wù)器低至59元/年，更有多臺(tái)、長(zhǎng)期優(yōu)惠，快來選購(gòu)！