Coroutine::create

创建一个新的协程,并立即执行。

  1. function Swoole\Coroutine::create(callable $function) : int|false;

参数

  • $function 协程执行的代码,必须为callable,系统能创建的协程总数量受限于server->max_coroutine设置

返回值

  • 创建失败返回false
  • 创建成功返回协程的ID

由于底层会优先执行子协程的代码,因此只有子协程挂起时,Coroutine::create才会返回,继续执行当前协程的代码。

2.1.0或更高版本中如果开启了swoole.use_shortname,可以直接使用go关键词创建新的协程。

  1. go(function () {
  2. $db = new Co\MySQL();
  3. $server = array(
  4. 'host' => '127.0.0.1',
  5. 'user' => 'root',
  6. 'password' => 'root',
  7. 'database' => 'test',
  8. );
  9. $db->connect($server);
  10. $result = $db->query('SELECT * FROM userinfo WHERE id = 3');
  11. var_dump($result);
  12. });

执行顺序

在一个协程中使用go嵌套创建新的协程。因为Swoole的协程是单线程模型,因此:

  • 使用go创建的子协程会优先执行,子协程执行完毕或挂起时,将重新回到父协程向下执行代码
  • 如果子协程挂起后,父协程退出,不影响子协程的执行
  1. go(function() {
  2. go(function () {
  3. co::sleep(3.0);
  4. go(function () {
  5. co::sleep(2.0);
  6. echo "co[3] end\n";
  7. });
  8. echo "co[2] end\n";
  9. });
  10. co::sleep(1.0);
  11. echo "co[1] end\n";
  12. });

协程开销

协程需要创建单独的内存栈,在PHP-7.2版本中底层会分配8Kstack来存储协程的变量,zval的尺寸为16字节,因此8Kstack最大可以保存512个变量。协程栈内存占用超过8KZendVM会自动扩容。

协程退出时会释放申请的stack内存。

PHP-7.1PHP-7.0默认会分配256K栈内存
可调用Co::set(['stack_size' => 4096])修改默认的栈内存尺寸