首页 > 其他分享 >hyperf 协程作用和相关的方法

hyperf 协程作用和相关的方法

时间：2024-08-21 16:26:39浏览次数：6  
标签：function 协程 Coroutine Hyperf hyperf sleep world 方法

什么是协程

协程是一种轻量级的线程，由用户代码来调度和管理，而不是由操作系统内核来进行调度，也就是在用户态进行

判断当前是否处于协程环境内

在一些情况下我们希望判断一些当前是否运行于协程环境内，
对于一些兼容协程环境与非协程环境的代码来说会作为一个判断的依据，
我们可以通过 Hyperf\Coroutine\Coroutine::inCoroutine(): bool 方法来得到结果。

创建协程的三种方式

Hyperf 是运行于 Swoole 4 的协程和 Swow 协程之上的，这也是 Hyperf 能提供高性能的其中一个很大的因素。

1. 通过co/go来创建协程

只需通过 co(callable $callable) 或 go(callable $callable) 函数或 Hyperf\Utils\Coroutine::create(callable $callable) 即可创建一个协程，协程内可以使用协程相关的方法和客户端

co

    public function co()
    {
        co(function () {
            sleep(1);
            echo "hello world 2 \n";
        });
        co(function () {
            sleep(1);
            echo "hello world 3 \n";
        });
    }

在这里插入图片描述

go

 public function go()
    {
        go(function () {
            sleep(2);
            echo "hello world 66 \n";
        });
        go(function () {
            sleep(1);
            echo "hello world 77 \n";
        });
    }

在这里插入图片描述

2. Coroutine::create

    public function coroutine()
    {
        Coroutine::create(function () {
            sleep(1);
            echo "hello world 88 \n";
        });
        Coroutine::create(function () {
            sleep(2);
            echo "hello world 99 \n";
        });
    }

在这里插入图片描述

    public function coroutine()
    {
        $coroutine = new Coroutine();
        $coroutine->create(function () {
            sleep(1);
            echo "hello world 33 \n";
        });
        $coroutine->create(function () {
            sleep(2);
            echo "hello world 44 \n";
        });
    }

在这里插入图片描述

3. 待完善

获得当前协程的 ID


    public function getCoroutineId()
    {
       
       $croutineId =  Coroutine::id();
       return json_encode(['croutineId'=> $croutineId]);
    }

在这里插入图片描述

Channel 通道

什么是channel呢，和go的chan一样，就是获取协程之间的数据通信

Channel 与 PHP 的数组类似，仅占用内存，没有其他额外的资源申请，所有操作均为内存操作，无 I/O 消耗，使用方法与 SplQueue 队列类似。

   public function channal(){
       $chan =  new \Swoole\Coroutine\Channel();
       co(function () use ($chan) {
        $chan->push('I am an alien');
        });
       $data =  $chan->pop();
       return json_encode(['data'=> $data]);
    }

在这里插入图片描述

Defer 特性

当我们希望在协程结束时运行一些代码时，可以通过 defer(callable $callable) 函数或 Hyperf\Coroutine::defer(callable $callable) 将一段函数以 栈(stack) 的形式储存起来，栈(stack) 内的函数会在当前协程结束时以 先进后出 的流程逐个执行。


    public function channal(){
       $chan =  new \Swoole\Coroutine\Channel();
       co(function () use ($chan) {
        $chan->push('I am an alien');
        defer(function(){
            $this->defers();
        });
        });

       $data =  $chan->pop();
       return json_encode(['data'=> $data]);
    }

    public function defers(){
          echo "hello world 111 \n";
    }

在这里插入图片描述
在这里插入图片描述

WaitGroup 特性

WaitGroup 是基于 Channel 衍生出来的一个特性，如果接触过 Go 语言，我们都会知道 WaitGroup 这一特性，在 Hyperf 里，WaitGroup 的用途是使得主协程一直阻塞等待直到所有相关的子协程都已经完成了任务后再继续运行，这里说到的阻塞等待是仅对于主协程（即当前协程）来说的，并不会阻塞当前进程。
我们通过一段代码来演示该特性：

    public function waitGroup(){
        $wg = new \Swoole\Coroutine\WaitGroup();
        $wg->add();
        go(function () use ($wg) {
            sleep(10);
            $wg->done();
        });
        go(function () use ($wg) {
            sleep(5);
            $wg->done();
        });
        $wg->wait();
        echo "hello world 55 \n";
    }

结果:
5秒后才执行主协程的内容

hello world 55

Parallel 特性

Parallel 特性是 Hyperf 基于 WaitGroup 特性抽象出来的一个更便捷的使用方法，我们通过一段代码来演示一下。

<?php
declare(strict_types=1);
namespace App\Controller;

use Hyperf\Utils\Exception\ParallelExecutionException;
use Hyperf\HttpServer\Annotation\AutoController;
use Hyperf\Utils\Coroutine;
use Hyperf\Utils\Parallel;

/**
 * @AutoController()
 */
class WaitGroupController extends AbstractController
{
           
    public function index()
    {
 
        $parallel = new Parallel();
        $parallel->add(function () {
            sleep(1);
            return Coroutine::id();
        });
        $parallel->add(function () {
            sleep(1);
            return Coroutine::id();
        });
    
        try{
            // $results 
        $results = $parallel->wait(); 
        return json_encode($results);
        } catch(ParallelExecutionException $e){
            // $e->getResults() 获取协程中的返回值。
            // $e->getThrowables() 获取协程中出现的异常。
            echo $e->getMessage() . PHP_EOL;
        }
    
    }   
}

在这里插入图片描述

上面的代码可以简化成下面的代码

<?php
use Hyperf\Utils\Coroutine;

// 传递的数组参数您也可以带上 key 便于区分子协程，返回的结果也会根据 key 返回对应的结果
$result = parallel([
    function () {
        sleep(1);
        return Coroutine::id();
    },
    function () {
        sleep(1);
        return Coroutine::id();
    }
]);

在这里插入图片描述

限制 Parallel 最大同时运行的协程数

防止访问过大，导致服务器崩溃，可以设置协程同时运行的最大数量
5就是限制数量的

$parallel = new Parallel(5);

完整代码

use Hyperf\Utils\Exception\ParallelExecutionException;
use Hyperf\Utils\Coroutine;
use Hyperf\Utils\Parallel;

$parallel = new Parallel(5);
for ($i = 0; $i < 20; $i++) {
    $parallel->add(function () {
        sleep(1);
        return Coroutine::id();
    });
} 

try{
   $results = $parallel->wait(); 
} catch(ParallelExecutionException $e){
    // $e->getResults() 获取协程中的返回值。
    // $e->getThrowables() 获取协程中出现的异常。
}

Concurrent 协程运行控制

Hyperf\Utils\Coroutine\Concurrent 基于 Swoole\Coroutine\Channel 实现，用来控制一个代码块内同时运行的最大协程数量的特性。
以下样例，当同时执行 10 个子协程时，会在循环中阻塞，但只会阻塞当前协程，直到释放出一个位置后，循环继续执行下一个子协程。

<?php

<?php
declare(strict_types=1);
namespace App\Controller;

use Hyperf\HttpServer\Annotation\AutoController;
use Hyperf\Utils\Coroutine\Concurrent;


/**
 * 
 * @AutoController()
 */
class WaitGroupController extends AbstractController
{
           
    public function index()
    {
 

        // 传递的数组参数您也可以带上 key 便于区分子协程，返回的结果也会根据 key 返回对应的结果

        $concurrent = new Concurrent(10);
        
        for ($i = 0; $i < 15; ++$i) {
            $concurrent->create(function () use ($i) {
                // Do something...
                print($i."\n");
            });
        }
        return json_encode( ['success'=>'success','count'=> $concurrent->count()]);
    
    }   
}

在这里插入图片描述
在这里插入图片描述

协程上下文

不能使用传统的php开发，把可变参数放到成员变量里，这样会导致不同协程之间数据混淆
所以出现了 协程上下文里存储可变参数

Hyperf\Utils\Context::set()

通过调用 set(string $id, $value) 方法储存一个值到当前协程的上下文中，如下：

<?php use Hyperf\Utils\Context; // 将 bar 字符串以 foo 为 key 储存到当前协程上下文中 $foo = Context::set('foo', 'bar'); // set 方法会再将 value 作为方法的返回值返回回来，所以 $foo 的值为 bar Copy to clipboardErrorCopied ## Hyperf\Utils\Context::get() 通过调用 get(string $id, $default = null) 方法可从当前协程的上下文中取出一个以 $id 为 key 储存的值，如不存在则返回 $default ，如下： <?php use Hyperf\Utils\Context; // 从当前协程上下文中取出 key 为 foo 的值，如不存在则返回 bar 字符串 $foo = Context::get('foo', 'bar'); Copy to clipboardErrorCopied ## Hyperf\Utils\Context::has() 通过调用 `has(string $id) `方法可判断当前协程的上下文中是否存在以 `$id `为 key 储存的值，如存在则返回 true，不存在则返回 false，如下： ```php <?php use Hyperf\Utils\Context; // 从当前协程上下文中判断 key 为 foo 的值是否存在 $foo = Context::has('foo'); ``` ## Hyperf\Utils\Context::override() 当我们需要做一些复杂的上下文处理，比如先判断一个 key 是否存在，如果存在则取出 value 来再对 value 进行某些修改，然后再将 value 设置回上下文容器中，此时会有比较繁杂的判断条件，可直接通过调用 override 方法来实现这个逻辑，如下： ```php <?php use Psr\Http\Message\ServerRequestInterface; use Hyperf\Utils\Context; // 从协程上下文取出 $request 对象并设置 key 为 foo 的 Header，然后再保存到协程上下文中 $request = Context::override(ServerRequestInterface::class, function (ServerRequestInterface $request) { return $request->withAddedHeader('foo', 'bar'); }); ``` ## Swoole Runtime Hook Level 框架在入口函数中提供了 SWOOLE_HOOK_FLAGS 常量，如果您需要修改整个项目的 Runtime Hook 等级，比如想要支持 CURL 协程 并且 Swoole 版本为 v4.5.4 之前的版本，可以修改这里的代码，如下。 ```php <?php ! defined('SWOOLE_HOOK_FLAGS') && define('SWOOLE_HOOK_FLAGS', SWOOLE_HOOK_ALL | SWOOLE_HOOK_CURL); ```

标签：function,协程,Coroutine,Hyperf,hyperf,sleep,world,方法
From： https://blog.csdn.net/xxpxxpoo8/article/details/141351368

相关文章

  • 什么是生信分析？深入探讨生物信息学的技术、方法与广泛应用
    介绍生物信息学分析，简称生信分析，是一个结合了生物学、计算机科学、信息学和统计学的多学科领域，旨在处理、分析和解释海量的生物数据。随着现代生物技术的发展，尤其是高通量测序（Next-GenerationSequencing,NGS）技术的广泛应用，生物研究的维度和深度都发生了巨大的变化。生信分......
  • 轻松将 iPad 备份到外部驱动器的 3 种快速方法
    为了确保您的iPad数据无忧安全，我们来谈谈如何将这些珍贵的信息备份到外部硬盘上。这不仅是一个明智的选择，而且也是一个简单的过程。无论是家庭照片、工作文档还是您最喜欢的音乐收藏，一旦您掌握了将iPad备份到外部硬盘的技巧，这些数据将像放在保险箱中一样安全。让我们一起来......
  • 解决lazarus 3.xx后在linux编译为Qt出错方法
    今天用lazarus3.4在银河麒麟将应用编译为Qt5出现以下错误信息：Warning:linker:/usr/bin/ld.bfd:/home/lb/fpcupdeluxe34/lazarus/lcl/units/aarch64-linux/qt5/qtint.o:infunction`QTINT$_$TQTWIDGETSET_$__$$_CREATE$$TQTWIDGETSET':Error:qtint.pp:(.text.n_qtint$_$t......
  • 去重方法
    一、使用Set  JavaScript的Set对象允许你存储唯一值，因此可以通过将数组转换为Set然后再转换回数组来去重。constarray=[1,2,2,3,4,4,5];constuniqueArray=[...newSet(array)];console.log(uniqueArray);//[1,2,3,4,5]二、使用filter......
  • 《泰拉瑞亚》ntdll.dll错误模块：原因、影响与解决方法
    遇到《泰拉瑞亚》（Terraria）游戏中出现ntdll.dll错误的情况通常意味着游戏在加载或运行过程中遇到了与Windows内核相关的严重问题。ntdll.dll是Windows操作系统的核心库之一，用于提供各种底层服务和功能。当这个DLL文件出现问题时，通常会影响到系统的稳定性和性能。下面将详细解......
  • LocalStorage 的使用方法
    LocalStorage是一种web端的存储机制，它使得由JavaScript编写的网站或者应用可以无限期的在浏览器中存储并访问数据。什么是无限期呢？就是说存储在浏览器中的数据是会一直存在的，及时浏览器被关闭了也不会消失。LocalStorage的使用方法要在你的web应用中使用LocalStorage，只......
  • store vue 仓库的使用方法
    1.项目介绍store.js是一个轻量级的JavaScript库，旨在封装浏览器的localStorage功能，以实现跨浏览器兼容的本地存储解决方案。它不需要依赖于Cookie或Flash，提供简单易用的API，使得开发者可以方便地进行键值对存储操作。基础使用以下是一些基础操作示例：//存储数据store......
  • 两种，统计各个方法的执行时间的写法
    publicclassT1{@Testvoidtest01(){longstartTime=System.currentTimeMillis();log.info("方法1开始执行，开始时间：{}",startTime);method01();longendTime=System.currentTimeMillis();log.info("方法1执......
  • 微信小程序SSL证书申请重点和方法
    微信小程序运行模式主要在手机微信内，这一套程序可以解决了用户注册账户及支付相关问题，另外使用很方便，用户不用特意的去安装小程序，只要在微信里面就可以开发，只因为这样微信小程序很受欢迎。对于开发者来说，小程序在加密协议过程，SSL证书起到了关键性的作用，也是微信小程序与微信交......
  • 在编程学习中克服挫折：心态调整、学习方法与成功经验
    引言编程学习之路，往往充满挑战与挫折。对于许多初学者来说，编程不仅是学习新知识，还涉及理解抽象的概念、解决复杂的问题、以及面对反复出现的错误。而即便是经验丰富的开发者，也会遇到新技术、新框架带来的挑战，以及在项目中遭遇的各种意外状况。无论在哪个阶段，挫折感都可能如同......

赞助商

阅读排行

网站主页关于我们联系我们网站地图

本网站内容转载自其他媒体，侵权联系[admin##ips99.com]。

Copyright © 2020-2023 IPS99 版权所有 IPS99