hyperf 协程作用和相关的方法

什么是协程

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

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

在一些情况下我们希望判断一些当前是否运行于协程环境内，
对于一些兼容协程环境与非协程环境的代码来说会作为一个判断的依据，
我们可以通过 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); ```

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.mfbz.cn/a/871817.html

如若内容造成侵权/违法违规/事实不符，请联系我们进行投诉反馈qq邮箱809451989@qq.com，一经查实，立即删除！

相关文章

使用html-docx-js + fileSaver实现前端导出word

使用html-docx-js + fileSaver实现前端导出word

因为html-docx-js是16年的老库了&#xff0c;它代码里面用到的with语法现在严格模式不允许&#xff0c;用npm直接引入会报错&#xff0c;所以我们需要用其它方式引入 首先要将html-docx-js的代码放到项目中 html-docx-js/dist/html-docx.js at master evidenceprime/html-do…
阅读更多...
modbus协议与RS-485协议的区别

modbus协议与RS-485协议的区别

在工业自动化领域&#xff0c;Modbus协议和RS-485通信协议都是常见且重要的技术标准。Modbus协议是一种通信协议&#xff0c;而RS-485则是一种物理层通信标准。 1.Modbus协议 Modbus协议是一种串行通信协议&#xff0c;最初由Modicon&#xff08;现为施耐德电气公司&#xff0…
阅读更多...
智能猫砂盆真的能代替双手铲屎吗？热门前三的智能猫砂盆推荐！

智能猫砂盆真的能代替双手铲屎吗？热门前三的智能猫砂盆推荐！

养猫的上班族最大的烦恼应该就是无法时刻为猫咪铲屎了吧&#xff0c;猫砂盆中的便便残留过久会发散臭味&#xff0c;甚至可能滋生细菌&#xff0c;招惹小飞虫&#xff0c;对家庭环境造成困扰&#xff0c;但是上班或出差又无法待在家中&#xff0c;时刻为猫咪待命&#xff0c;以…
阅读更多...
Java二十三种设计模式-解释器模式（23/23）

Java二十三种设计模式-解释器模式（23/23）

本文深入探讨了解释器模式&#xff0c;这是一种行为设计模式&#xff0c;用于构建和解释执行自定义语言&#xff0c;提供了实现方法、优点、缺点、与其他模式的比较、最佳实践和替代方案的全面分析&#xff0c;帮助开发者在实际应用中做出明智的设计选择。 解释器模式&#xff…
阅读更多...
【css】伪元素实现图片个悬停文字聚焦效果

【css】伪元素实现图片个悬停文字聚焦效果

实现重点&#xff1a; 文字覆盖在图片上&#xff1a; 通过使用 position: absolute 将 .box 文字盒子定位在图片上方。父容器 .img-wrap 使用了 position: relative 确保子元素的绝对定位在父容器的边界内生效。 创建悬停效果&#xff1a; 通过使用 &::before 和 &::…
阅读更多...
探索Unity3D URP后处理在UI控件Image上的应用

探索Unity3D URP后处理在UI控件Image上的应用

探索Unity3D URP后处理在UI控件Image上的应用 前言初识URP配置后处理效果将后处理应用于UI控件方法一&#xff1a;自定义Shader方法二&#xff1a;RenderTexture的使用 实践操作步骤一&#xff1a;创建RenderTexture步骤二&#xff1a;UI渲染至RenderTexture步骤三&#xff1a;…
阅读更多...
普元EOS-基于CriteriaEntity进行数据查询

普元EOS-基于CriteriaEntity进行数据查询

1 前言 普元EOS内置了一系列数据库的操作类&#xff0c;本文介绍其中的一个类 CriteriaEntity的使用方法。 CriteriaEntity是进行组织数据库查询条件的类&#xff0c;基于该类配合DataObject&#xff0c;实现对数据库的查询。 2 CriteriaType类的实例化 要利用Criteria进行查…
阅读更多...
七个电脑数据恢复方法：教你如何恢复电脑上误删除的文件

七个电脑数据恢复方法：教你如何恢复电脑上误删除的文件

电脑已成为我们日常生活和工作中不可或缺的一部分&#xff0c;存储着无数珍贵的照片、文档、视频以及各类重要数据。今天来和大家分享一个我们都可能遇到的问题&#xff1a;如何恢复电脑上误删除的文件&#xff1f;随着日常操作的频繁&#xff0c;误删除文件的情况时有发生。 …
阅读更多...
vue3【组件封装】日历 （默认标注今日，可选择日期，可标注日期，可切换月份，样式仿 Win11）

vue3【组件封装】日历 （默认标注今日，可选择日期，可标注日期，可切换月份，样式仿 Win11）

效果预览 技术要点 获取每个月最后一天 下个月的第0天，自动会被解析为本月的最后一天 let lastDay = computed(() => new Date(year.value, month.value, 0).getDate());flex 布局末行左对齐 最靠谱的方式是想办法将末行缺失元素填满 本范例中，因星期固定7列，按每月最…
阅读更多...
在控件graphicsView中实现绘图功能（二）

在控件graphicsView中实现绘图功能（二）

目录 前言&#xff1a;基础夯实&#xff1a;1.创建 QGraphicsScene 和 QGraphicsView2. 在 QGraphicsScene 中添加椭圆3. 渲染和显示4. 推荐学习本文之前查看的链接&#xff1a; 效果展示&#xff1a;实现功能&#xff1a;遇到问题&#xff1a;核心代码&#xff1a;仓库源码&am…
阅读更多...
OpenCV几何图像变换（6）计算反转仿射变换函数invertAffineTransform()的使用

OpenCV几何图像变换（6）计算反转仿射变换函数invertAffineTransform()的使用

操作系统&#xff1a;ubuntu22.04 OpenCV版本&#xff1a;OpenCV4.9 IDE:Visual Studio Code 编程语言&#xff1a;C11 算法描述 反转一个仿射变换。 该函数计算由 23 矩阵 M 表示的逆仿射变换&#xff1a; [ a 11 a 12 b 1 a 21 a 22 b 2 ] \begin{bmatrix} a_{11} & a…
阅读更多...
检测到目标URL存在http host头攻击漏洞

检测到目标URL存在http host头攻击漏洞

漏洞描述 修复措施 方法一&#xff1a; nginx 的 default_server 指令可以定义默认的 server 去处理一些没有匹配到 server_name 的请求&#xff0c;如果没有显式定义&#xff0c;则会选取第一个定义的 server 作为 default_server。 server { …
阅读更多...
缓存实现方式

缓存实现方式

缓存是一个常见的话题&#xff0c;因为它对于提高应用程序性能至关重要。缓存是一种存储数据的临时地方&#xff0c;以便快速访问数据&#xff0c;减少对原始数据源&#xff08;如数据库或文件系统&#xff09;的访问次数&#xff0c;从而提高应用程序的响应速度和吞吐量。 Jav…
阅读更多...
性能测试全解

性能测试全解

世界上没有陌生人&#xff0c;只有还没认识的朋友 一&#xff0e;性能测试的意义 由于软件系统的性能问题而引起严重后果的事件比比皆是&#xff0c;下面列举几个案例 (1)2007年10月&#xff0c;北京奥组委实行2008年奥运会门票预售&#xff0c;一时间订票官网访问量激致系统…
阅读更多...
Ciallo～(∠・ω・ )⌒☆第二十篇 入门mysql 数据库

Ciallo～(∠・ω・ )⌒☆第二十篇 入门mysql 数据库

要入门MySQL数据库&#xff0c;首先需要了解数据库的基本概念和原理。MySQL是一种广泛使用的开源关系型数据库管理系统&#xff0c;它能够处理大量的数据&#xff0c;并提供了多种功能。 一、创建数据库 连接到MySQL后&#xff0c;你可以使用SQL语句来创建数据库。例如&#x…
阅读更多...
libevent之android与鸿蒙编译过程

libevent之android与鸿蒙编译过程

背景 最近基于libevent开发了一个端侧的缓存代理库&#xff0c;先是基于macOS编译开发的&#xff0c;基本0问题&#xff0c;后来移植到鸿蒙与android时遇到一些编译链接问题。 libevent版本如下&#xff1a; 软件版本号libevent-2.1.8 android编译 编译环境 android studio…
阅读更多...
docker部署postgresSQL 并做持久化

docker部署postgresSQL 并做持久化

先安装docker&#xff0c;安装docker 方法自行寻找方法 然后安装pgsql 拉取镜像 docker pull registry.cn-hangzhou.aliyuncs.com/qiluo-images/postgres:latest运行容器 docker run -it --name postgres --privileged --restart always -e POSTGRES_PASSWORDYo5WYypu0mCCh…
阅读更多...
input[type=checkbox]勾选框自定义样式

input[type=checkbox]勾选框自定义样式

效果图&#xff1a; <template> <input class"rule-checkbox" type"checkbox" checked v-model"isChecked" /> </template><script setup lang"ts"> import { ref } from vue; const isChecked ref(); </…
阅读更多...
Python3：多行文本内容转换为标准的cURL请求参数值

Python3：多行文本内容转换为标准的cURL请求参数值

背景 在最近的工作中&#xff0c;经常需要处理一些接口请求的参数&#xff0c;参数来源形式很多&#xff0c;可能是Excel、知识库文档等&#xff0c;有些数据形式比较复杂&#xff0c;比如多行或者包含很多不同的字符&#xff0c;示例如下&#xff1a; **客服质检分析指引** …
阅读更多...
性价比运动耳机有哪些？五大性价比运动耳机推荐！

性价比运动耳机有哪些？五大性价比运动耳机推荐！

作为一名资深的数码爱好者&#xff0c;我一直对各种新型耳机产品保持着浓厚的兴趣。最近&#xff0c;我因为很多运动爱好者都在询问什么耳机是比较适合运动的时候使用的&#xff0c;看了市面上的产品&#xff0c;开放式耳机无疑是一个不错的选择&#xff0c;它因为采用人体工学…
阅读更多...
最新文章

Copyright @ 2022~2023