Mix PHP V2 新特性：協(xié)程、定時(shí)器

Nosee 發(fā)布于2019-07-01 12:39 / 1461人閱讀

摘要：主函數(shù)查詢(xún)數(shù)據(jù)不手動(dòng)釋放的連接不會(huì)歸還連接池，會(huì)在析構(gòu)時(shí)丟棄執(zhí)行結(jié)果為，說(shuō)明是并行執(zhí)行的。主函數(shù)查詢(xún)數(shù)據(jù)即便拋出了異常，仍然能執(zhí)行到，沒(méi)有導(dǎo)致內(nèi)的一直處于阻塞狀態(tài)。主函數(shù)一次性定時(shí)持續(xù)定時(shí)停止定時(shí)

協(xié)程

Mix PHP V2 基于 Swoole 4 的 PHP Stream Hook 協(xié)程技術(shù)開(kāi)發(fā)，協(xié)程使用方式與 Golang 幾乎一致，包括框架封裝的協(xié)程池、連接池、命令行處理都大量參考了 Golang 的系統(tǒng)庫(kù)風(fēng)格。

除了缺少 select case 外，Mix PHP 與 Golang 的協(xié)程幾乎一致，框架還提供了連接池、協(xié)程池、命令行處理這些開(kāi)箱即用的封裝。

xgo + Channel

xgo 類(lèi)似 Golang 的 go 關(guān)鍵字，可啟動(dòng)一個(gè)新的協(xié)程，Channel 等于 Golang 的 chan 類(lèi)，負(fù)責(zé)在不同協(xié)程中傳遞數(shù)據(jù)。


 */
class CoroutineCommand
{

    /**
     * 主函數(shù)
     */
    public function main()
    {
        xgo(function () {
            $time = time();
            $chan = new Channel();
            for ($i = 0; $i < 2; $i++) {
                xgo([$this, "foo"], $chan);
            }
            for ($i = 0; $i < 2; $i++) {
                $result = $chan->pop();
            }
            println("Total time: " . (time() - $time));
        });
        Event::wait();
    }

    /**
     * 查詢(xún)數(shù)據(jù)
     * @param Channel $chan
     */
    public function foo(Channel $chan)
    {
        $db     = app()->dbPool->getConnection();
        $result = $db->createCommand("select sleep(5)")->queryAll();
        $db->release(); // 不手動(dòng)釋放的連接不會(huì)歸還連接池，會(huì)在析構(gòu)時(shí)丟棄
        $chan->push($result);
    }

}

執(zhí)行結(jié)果為 5s，說(shuō)明是并行執(zhí)行的。

WaitGroup + xdefer

WaitGroup 與 Golang 的完全一致，xdefer 方法也等同于 Golang 的 defer 關(guān)鍵字。

當(dāng)并行執(zhí)行且不需要返回結(jié)果時(shí)，可以使用 WaitGroup + xdefer，xdefer 即使在方法拋出異常時(shí)，仍然會(huì)執(zhí)行，這樣能避免一直處于阻塞狀態(tài)。


 */
class WaitGroupCommand
{

    /**
     * 主函數(shù)
     */
    public function main()
    {
        xgo(function () {
            $wg = WaitGroup::new();
            for ($i = 0; $i < 2; $i++) {
                $wg->add(1);
                xgo([$this, "foo"], $wg);
            }
            $wg->wait();
            println("All done!");
        });
        Event::wait();
    }

    /**
     * 查詢(xún)數(shù)據(jù)
     * @param WaitGroup $wg
     */
    public function foo(WaitGroup $wg)
    {
        xdefer(function () use ($wg) {
            $wg->done();
        });
        println("work");
        throw new RuntimeException("ERROR");
    }

}

即便拋出了 RuntimeException 異常，仍然能執(zhí)行到 println("All done!");，沒(méi)有導(dǎo)致 wg 內(nèi)的 chan 一直處于阻塞狀態(tài)。

定時(shí)器

異步編程中，定時(shí)器的使用非常頻繁。

Timer::new() 可獲得一個(gè)實(shí)例

after 方法可設(shè)置一次性定時(shí)

tick 方法可設(shè)置持續(xù)定時(shí)

停止當(dāng)前定時(shí)期，只需只需對(duì)象的 $timer->clear(); 方法。


 */
class TimerCommand
{

    /**
     * 主函數(shù)
     */
    public function main()
    {
        // 一次性定時(shí)
        Timer::new()->after(1000, function () {
            println(time());
        });

        // 持續(xù)定時(shí)
        $timer = new Timer();
        $timer->tick(1000, function () {
            println(time());
        });

        // 停止定時(shí)
        Timer::new()->after(10000, function () use ($timer) {
            $timer->clear();
        });

        Event::wait();
    }

}

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

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

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

登陸后可評(píng)論

0條評(píng)論

Nosee

男|高級(jí)講師

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

TA的文章

天冷了，任務(wù)欄養(yǎng)只貓吧「GitHub 熱點(diǎn)速覽 v.21.46」

閱讀 2919·2021-11-15 18:02
程序猿的武林秘籍,使用vscode一鍵調(diào)試代碼

閱讀 3814·2021-10-14 09:43
新網(wǎng)：限時(shí)7個(gè)域名(.xyz,.ltd,.fun,.online,.shop,.site,.spac

閱讀 3753·2021-09-08 10:41
最近遇到的前端面試題(2017.03.08更新版)

閱讀 2529·2019-08-30 15:53
CSS常用功能代碼集錦

閱讀 1812·2019-08-30 14:14
畫(huà)布、拖放事件、音視頻

閱讀 1958·2019-08-29 16:12
雜談 CSS IN JS

閱讀 3153·2019-08-29 14:03
提高 Web開(kāi)發(fā)性能的 10 個(gè)方法

閱讀 1286·2019-08-29 13:46

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

資訊專(zhuān)欄INFORMATION COLUMN

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

Mix PHP V2 新特性：協(xié)程、定時(shí)器

相關(guān)文章

Mix PHP V2 實(shí)例：AliCloud 短信協(xié)程池異步發(fā)送守護(hù)程序

Mix PHP V2 實(shí)例：協(xié)程池異步郵件發(fā)送守護(hù)程序

***Mix* PHP V2 生態(tài)：讓 Guzzle 支持 Swoole 的 Hook *協(xié)程***

swoole入門(mén)1-認(rèn)識(shí)swoole

**Laravel5.4新特性-Laravel-mix和laravel-elixir比較**

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

0條評(píng)論

Nosee

男|高級(jí)講師

TA的文章

天冷了，任務(wù)欄養(yǎng)只貓吧「GitHub 熱點(diǎn)速覽 v.21.46」

程序猿的武林秘籍,使用vscode一鍵調(diào)試代碼

新網(wǎng)：限時(shí)7個(gè)域名(.xyz,.ltd,.fun,.online,.shop,.site,.spac

最近遇到的前端面試題(2017.03.08更新版)

CSS常用功能代碼集錦

畫(huà)布、拖放事件、音視頻

雜談 CSS IN JS

提高 Web開(kāi)發(fā)性能的 10 個(gè)方法

最新活動(dòng)

資訊專(zhuān)欄INFORMATION COLUMN

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

Mix PHP V2 新特性：協(xié)程、定時(shí)器

相關(guān)文章

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

0條評(píng)論

男|高級(jí)講師

TA的文章

最新活動(dòng)

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

Mix PHP V2 新特性：協(xié)程、定時(shí)器