PHP協程中Go+Chan+Defer的示例分析

這篇文章主要為大家展示了“PHP協程中Go+Chan+Defer的示例分析”,內容簡而易懂,條理清晰,希望能夠幫助大家解決疑惑,下面讓小編帶領大家一起研究并學習一下“PHP協程中Go+Chan+Defer的示例分析”這篇文章吧。

10年的淅川網站建設經驗,針對設計、前端、開發、售后、文案、推廣等六對一服務,響應快,48小時及時工作處理。成都營銷網站建設的優勢是能夠根據用戶設備顯示端的尺寸不同,自動調整淅川建站的顯示方式,使網站能夠適用不同顯示終端,在瀏覽器中調整網站的寬度,無論在任何一種瀏覽器上瀏覽網站,都能展現優雅布局與設計,從而大程度地提升瀏覽體驗。創新互聯公司從事“淅川網站設計”,“淅川網站推廣”以來,每個客戶項目都認真落實執行。

Swoole4為PHP語言提供了強大的CSP協程編程模式。底層提供了3個關鍵詞,可以方便地實現各類功能

Swoole4提供的PHP協程語法借鑒自Golang,在此向GO開發組致敬

PHP+Swoole協程可以與Golang很好地互補。Golang:靜態語言,嚴謹強大性能好,PHP+Swoole:動態語言,靈活簡單易用

關鍵詞

  •  go :創建一個協程

  •  chan :創建一個通道

  •  defer :延遲任務,在協程退出時執行,先進后出

這3個功能底層實現全部為內存操作,沒有任何IO資源消耗。就像PHP的Array一樣是非常廉價的。如果有需要就可以直接使用。這與socket和file操作不同,后者需要向操作系統申請端口和文件描述符,讀寫可能會產生阻塞的IO等待。

協程并發

使用go函數可以讓一個函數并發地去執行。在編程過程中,如果某一段邏輯可以并發執行,就可以將它放置到go協程中執行。

順序執行

function test1()   {      sleep(1);      echo "b";  }  function test2()   {      sleep(2);      echo "c";  }  test1();  test2();

執行結果:

htf@LAPTOP-0K15EFQI:~$ time php b1.php  bc  real    0m3.080s  user    0m0.016s  sys     0m0.063s  htf@LAPTOP-0K15EFQI:~$

上述代碼中,test1和test2會順序執行,需要3秒才能執行完成。

并發執行

使用go創建協程,可以讓test1和test2兩個函數變成并發執行。

Swoole\Runtime::enableCoroutine();  go(function ()   {      sleep(1);      echo "b";  });    go(function ()   {      sleep(2);      echo "c";  });

Swoole\Runtime::enableCoroutine()作用是將PHP提供的stream、sleep、pdo、MySQLi、redis等功能從同步阻塞切換為協程的異步IO

執行結果:

bchtf@LAPTOP-0K15EFQI:~$ time php co.php  bc  real    0m2.076s  user    0m0.000s  sys     0m0.078s  htf@LAPTOP-0K15EFQI:~$

可以看到這里只用了2秒就執行完成了。

  •  順序執行耗時等于所有任務執行耗時的總和 :t1+t2+t3...

  •  并發執行耗時等于所有任務執行耗時的***值 :max(t1, t2, t3, ...)

協程通信

有了go關鍵詞之后,并發編程就簡單多了。與此同時又帶來了新問題,如果有2個協程并發執行,另外一個協程,需要依賴這兩個協程的執行結果,如果解決此問題呢?

答案就是使用通道(Channel),在Swoole4協程中使用new chan就可以創建一個通道。通道可以理解為自帶協程調度的隊列。它有兩個接口push和pop:

  •  push:向通道中寫入內容,如果已滿,它會進入等待狀態,有空間時自動恢復

  •  pop:從通道中讀取內容,如果為空,它會進入等待狀態,有數據時自動恢復

使用通道可以很方便地實現并發管理。

$chan = new chan(2);  # 協程1  go (function () use ($chan) {      $result = [];      for ($i = 0; $i < 2; $i++)      {          $result += $chan->pop();      }      var_dump($result);  });  # 協程2  go(function () use ($chan) {     $cli = new Swoole\Coroutine\Http\Client('www.qq.com', 80);         $cli->set(['timeout' => 10]);         $cli->setHeaders([         'Host' => "www.qq.com",         "User-Agent" => 'Chrome/49.0.2587.3',         'Accept' => 'text/html,application/xhtml+xml,application/xml',         'Accept-Encoding' => 'gzip',     ]);     $ret = $cli->get('/');     // $cli->body 響應內容過大,這里用 Http 狀態碼作為測試     $chan->push(['www.qq.com' => $cli->statusCode]);  });  # 協程3  go(function () use ($chan) {     $cli = new Swoole\Coroutine\Http\Client('www.163.com', 80);     $cli->set(['timeout' => 10]);     $cli->setHeaders([         'Host' => "www.163.com",         "User-Agent" => 'Chrome/49.0.2587.3',         'Accept' => 'text/html,application/xhtml+xml,application/xml',         'Accept-Encoding' => 'gzip',     ]);     $ret = $cli->get('/');     // $cli->body 響應內容過大,這里用 Http 狀態碼作為測試     $chan->push(['www.163.com' => $cli->statusCode]);  });

執行結果:

htf@LAPTOP-0K15EFQI:~/swoole-src/examples/5.0$ time php co2.php  array(2) {    ["www.qq.com"]=>    int(302)    ["www.163.com"]=>    int(200) }  real    0m0.268s  user    0m0.016s  sys     0m0.109s  htf@LAPTOP-0K15EFQI:~/swoole-src/examples/5.0$

這里使用go創建了3個協程,協程2和協程3分別請求qq.com和163.com主頁。協程1需要拿到Http請求的結果。這里使用了chan來實現并發管理。

  •  協程1循環兩次對通道進行pop,因為隊列為空,它會進入等待狀態

  •  協程2和協程3執行完成后,會push數據,協程1拿到了結果,繼續向下執行

延遲任務

在協程編程中,可能需要在協程退出時自動實行一些任務,做清理工作。類似于PHP的register_shutdown_function,在Swoole4中可以使用defer實現。

Swoole\Runtime::enableCoroutine();  go(function () {      echo "a";      defer(function () {          echo "~a";      });      echo "b";      defer(function () {          echo "~b";      });      sleep(1);      echo "c";  });

執行結果:

htf@LAPTOP-0K15EFQI:~/swoole-src/examples/5.0$ time php defer.php  abc~b~a  real    0m1.068s  user    0m0.016s  sys     0m0.047s  htf@LAPTOP-0K15EFQI:~/swoole-src/examples/5.0$

以上是“PHP協程中Go+Chan+Defer的示例分析”這篇文章的所有內容,感謝各位的閱讀!相信大家都有了一定的了解,希望分享的內容對大家有所幫助,如果還想學習更多知識,歡迎關注創新互聯行業資訊頻道!

當前標題:PHP協程中Go+Chan+Defer的示例分析
轉載源于:http://m.kartarina.com/article6/pipjig.html

成都網站建設公司_創新互聯,為您提供移動網站建設、搜索引擎優化、網站制作域名注冊微信小程序網站維護

廣告

聲明:本網站發布的內容(圖片、視頻和文字)以用戶投稿、用戶轉載內容為主,如果涉及侵權請盡快告知,我們將會在第一時間刪除。文章觀點不代表本網站立場,如需處理請聯系客服。電話:028-86922220;郵箱:631063699@qq.com。內容未經允許不得轉載,或轉載時需注明來源: 創新互聯

搜索引擎優化
主站蜘蛛池模板: 亚洲AV成人无码久久精品老人| 一区二区三区人妻无码| 亚洲AV色无码乱码在线观看| 免费无码黄十八禁网站在线观看| 下载天堂国产AV成人无码精品网站 | 午夜无码性爽快影院6080| 日韩av无码国产精品| 亚洲AV无码一区二区乱孑伦AS| 无码丰满熟妇juliaann与黑人| 久久99久久无码毛片一区二区| 无码精品久久久天天影视 | 亚洲无码视频在线| 亚洲av中文无码乱人伦在线观看| 久久99久久无码毛片一区二区 | 日本精品人妻无码免费大全| 国产AV无码专区亚洲AWWW| 日韩中文无码有码免费视频| 久久久久久无码Av成人影院 | 久久久久无码国产精品一区| 国产精品爽爽V在线观看无码| 日韩av无码中文字幕| 亚洲成av人片在线观看无码不卡| 性色AV无码中文AV有码VR| 西西444www无码大胆| 6080YYY午夜理论片中无码| 亚洲av永久无码精品秋霞电影影院| 亚洲精品无码成人片在线观看 | 深夜a级毛片免费无码| 久久亚洲中文无码咪咪爱| 67194成l人在线观看线路无码| 日日摸日日踫夜夜爽无码| 亚洲AV人无码激艳猛片| 亚洲成AV人在线播放无码| 国产成人无码一区二区在线播放 | 亚洲精品无码久久久影院相关影片 | 亚洲av无码专区在线| 人妻无码一区二区三区免费| 久久无码专区国产精品发布| 久久久久久久人妻无码中文字幕爆| 无码丰满少妇2在线观看| av潮喷大喷水系列无码|