[TOC] ## 概述 ``` 協程是并發執行的 ``` ## 簡單 demo ``` public function index(){ for ($i=0; $i < 10; $i++) { go(function () use ($i){ echo "go ".$i; \co::sleep(3);//在協程中 sleep,不影響主進程 //sleep(3); // 影響住進程,3 秒后執行下一個協程 }); } $this->writeJson(200,"ok"); } ``` ## 處理上下文 ``` public function index(){ go(function (){ ContextManager::getInstance()->set('key','key in parent'); go(function (){ ContextManager::getInstance()->set('key','key in sub'); var_dump(ContextManager::getInstance()->get('key')." in"); }); \co::sleep(5);//不在主進程 sleep ,返回結果不會 sleep var_dump(ContextManager::getInstance()->get('key')." out"); }); /** * string(13) "key in sub in" string(17) "key in parent out" */ $this->writeJson(200,"ok"); } ``` ## WaitGroup ``` go(function (){ $ret = []; $wait = new \EasySwoole\Component\WaitGroup(); $wait->add(); go(function ()use($wait,&$ret){ \co::sleep(0.1); $ret[] = time(); $wait->done(); }); $wait->add(); go(function ()use($wait,&$ret){ \co::sleep(2); $ret[] = time(); $wait->done(); }); $wait->wait(); var_dump($ret); }); ``` [TOC]