php curl header_PHP中的yield与协程(二十一节)

大家好,我是老李。

顺风说骚话,逆风讲道理

最近在大家一起努力下,那个沙雕肺炎患病人数增长率下降了不少,总体来说还算顺,所以今天这篇注定又要骚话连篇了。听说最近不少玉米开始向大连、威海、烟台方向涌入,算是潜在的风险吧,总之,大家也都别放松警惕,不要看到曙光时候给撂倒了。

上一节课我们说的主要是在谢顶道人 --- 老李的提示下,你初步使用了yield...那个你没有名字也不好,给你起个名字,洋气点儿就叫欧阳吧,一听就是个贵族富少继承者们。

喊人先喊亲,要把读者叫舒心

文章别嫌少,得把客官伺候好

开工第一天,你的老板原上草又交给你一个任务并信誓旦旦地答应你如果你能顺利完成任务那么这个月的打卡迟到费就不扣你的了。强大的利好信息让你欲罢不能。事情是这样的,还是上一集那个内存只有100KB的单片机,这个单片机会访问三方服务公司的一个API,但有时候这个API会抽风,老板原上草的意思是这会儿不要阻塞等待而是让这个单片机干点儿别的事儿,等API访问OK了再让TA回来,总之别让TA闲着,算是免费送这个单片机一个满满的福报。

考虑到昨天谢顶道人曾经给你科普过的yield似乎拥有一种让出CPU实现用户调度的能力,你决定展现一波儿自我,而谢顶道人也决定用那双充满了老茧子的手手把手辅导你。

<?php function gen1() {  for( $i = 1; $i <= 10; $i++ ) {    echo "GEN1 : {$i}".PHP_EOL;    // sleep没啥意思,主要就是运行时候给你一种切实的调度感,你懂么    sleep( 1 );    // 这句很关键,表示自己主动让出CPU,我不下地狱谁下地狱    yield;  }}function gen2() {  for( $i = 1; $i <= 10; $i++ ) {    echo "GEN2 : {$i}".PHP_EOL;    // sleep没啥意思,主要就是运行时候给你一种切实的调度感,你懂么    sleep( 1 );    // 这句很关键,表示自己主动让出CPU,我不下地狱谁下地狱    yield;  }}$task1 = gen1();$task2 = gen2();while( true ) {  // 首先我运行task1,然后task1主动下了地狱  echo $task1->current();  // 这会儿我可以让task2介入进来了  echo $task2->current();  // task1恢复中断  $task1->next();  // task2恢复中断  $task2->next();}

7fa35bff58462d67bc380d4f40bcc515.png

GET不到发生了什么,是吗?就是gen1()和gen2()可以交替运行并且每次都是接着从上次的地方开始运行,你要用传统的function是完全做不到的,传统的function只能一口气先完成其中一个函数中的for()然后再能完成另外一个function中的for(),比如下面这坨:

<?php function gen1() {  for( $i = 1; $i <= 10; $i++ ) {    echo "GEN1 : {$i}".PHP_EOL;    sleep( 1 );  }}function gen2() {  for( $i = 1; $i <= 10; $i++ ) {    echo "GEN2 : {$i}".PHP_EOL;  }}gen1();gen2();// 看这里,看这里,看这里!// 上面的代码一旦运行,一定是先运行完gen1函数中的for循环// 其次才能运行完gen2函数中的for循环,绝对不会出现// gen1和gen2交叉运行这种情况

我似乎已然精通了yield

788c64ab5c7334d3da9df2c4e3f261d2.gif

好了欧阳,让我们展示真正的技术吧!下面这个demo,如果访问某个API阻塞的话就主动让出CPU,然后让出的CPU开始往一个文件里写字符串...反正不能让TA闲着:

<?php $ch1 = curl_init();// 这个地址中的php,我故意sleep了5秒钟,然后输出一坨jsoncurl_setopt( $ch1, CURLOPT_URL, "http://www.selfctrler.com/index.php/test/test1" );curl_setopt( $ch1, CURLOPT_HEADER, 0 );$mh = curl_multi_init();curl_multi_add_handle( $mh, $ch1 );// gen1中就是调用三方API,基于multi-curl实现function gen1( $mh, $ch1 ) {  do {    $mrc = curl_multi_exec( $mh, $running );    // 请求发出后,让出cpu    $rs = yield;    // 生产环境千万别这么干......    // 这里加sleep是为了让你看的更清楚流程    sleep( 1 );    echo "收到外部发送数据{$rs}".PHP_EOL;      } while( $running > 0 );  $ret = curl_multi_getcontent( $ch1 );  echo $ret.PHP_EOL;  return false;}// gen2是写文件...function gen2() {  for ( $i = 1; $i <= 10; $i++ ) {    echo "gen2 : {$i}".PHP_EOL;    file_put_contents( "./yield.log", "gen2".$i.PHP_EOL, FILE_APPEND );    $rs = yield;    // 生产环境千万别这么干......    // 这里加sleep是为了让你看的更清楚流程    sleep( 1 );    echo "收到外部发送数据{$rs}".PHP_EOL;      }}$gen1 = gen1( $mh, $ch1 );$gen2 = gen2();while( true ) {  echo $gen1->current();  echo $gen2->current();  $gen1->send("gen1");  $gen2->send("gen2");}

上面这坨代码在飞起来后,我们再等待curl发起请求的5秒钟内,同时可以完成文件写入功能,如果换做平时的PHP程序,就只能是先阻塞等待curl拿到结果后才能完成文件写入,有了一丝丝内味儿了吗?

协程味儿

但是这里必须要值得注意的是,欧阳在gen1()的代码里用的并不是我们一般时候用的curl方法,而是curl_multi_exec(),为啥呢?因为一般般我们最常用的PHP curl方法都是阻塞的,这很致命,这里要点就是:全程不能阻塞,阻塞一处死翘翘。实际上这里最标准的用法就是curl_multi_exec()配合curl_multi_select()。所以,扩散一下思维如果你用file_get_contents()也是不行的。

下面由谢顶道人总结一个PHP中yield的典型使用方法:如果要使用yield实现「异步」,实际上在PHP里也只能是结合select或epoll这些IO服用,具体就是当IO没有ready的时候,yield出让CPU去做别的事情,一旦IO ready了就回来继续执行原来的任务,说白了就是协程调度器!

???

那TM我要这yield到底有啥用?谢顶道人你咋这幽默呢?感觉蒙娜丽莎都是你逗笑的呢~我直接用之前章节里基于libevent实现的服务器不就挺好用的吗?这里要说的就是「基于IO复用实现的异步非阻塞服务器中难以避免的异步回调地狱」写法,说白了就是一层又一层嵌套的on。这在NodeJS里颇为常见,所以后来NodeJS出了一个叫做Promise的关键字来缓解这个问题,这里你可以粗暴的认为yield就是PHP版本的Promise,就是传说中的「用传统同步代码的写法写异步」,但也依然能写出高IO的程序。

世面上有什么典型作品吗?有啊,swoole呀,swoole协程就是基于epoll实现的协程调度器;还有微信开源的libco也基本上是基于IO复用实现的协程调度器。要注意的基于epoll实现协程调度器只是一种实现方式而已,像Golang则是完全是自己在上层实现的调度器。

好看的皮囊就是好看,有趣的灵魂爱咋咋滴...

68a5592947b988c0c59fba1c52701740.png

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

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

python增加一列数据_Python编程给numpy矩阵添加一列方法示例

首先我们有一个数据是一个mn的numpy矩阵现在我们希望能够进行给他加上一列变成一个m(n1)的矩阵 import numpy as np a np.array([[1,2,3],[4,5,6],[7,8,9]]) b np.ones(3) c np.array([[1,2,3,1],[4,5,6,1],[7,8,9,1]]) PRint(a) print(b) print(c) [[1 2 3] [4 5 6] [7 8 9…

用稳压管保护单片机引脚_一步一步,全程揭开单片机的原理,让做电子变得轻松自如!...

学习单片机必要的硬件学习单片机都需要什么&#xff1f;首先要掌握必要的电子基础知识&#xff1b;再次选择大众化、性价比高的单片机&#xff0c;熟悉它的引脚功能定义&#xff1b;另外还需要电脑与下载程序的下载器。一、单片机建议选择型号为STC89C52RC单片机&#xff0c;如…

python word 表格宽度_RPA手把手——python-docx 设置 word 文档中表格格式

艺赛旗|做RPA生态先行者 RPA10.0全新首发免费下载 点击下载 引入会用到的库 from docx import Document from docx.shared import Pt from docx.enum.text import WD_PARAGRAPH_ALIGNMENT from docx.shared import Cm from docx.shared import RGBColor 表格样式 #方法一&#…

软引用和弱引用的区别_强、软、弱、虚引用的区别和使用

原文阅读&#xff1a;强、软、弱、虚引用的区别和使用​mp.weixin.qq.comJava提供了四种级别的应用类型&#xff1a;强引用、软引用、弱引用及虚引用。那么这四种引用类型有什么区别呢&#xff1f;首先我们通过一张图来看看四种引用在Java中的表示&#xff1a;FinalReference由…

python的print输出_python中的print()输出

1.普通的输出&#xff1a; print(str)#str是任意一个字符串&#xff0c;数字・・・ 2.格式化输出&#xff1a; print(1,2,%s,%d%(asd,4)) 1,2,asd,4 与C语言有点类似 3.其它&#xff1a; >>> pi 3.141592653 >>> print(%10.3f % pi) #字段宽10&#xff0c;精…

python文本文件不能用二进制文件方式读入_如何使用python函数以二进制形式读取文件?...

虽然读取文件的方式各种各样&#xff0c;但是通过二进制&#xff0c;还是头一次&#xff0c;实现过过程并不难&#xff0c;我们需要将文件先做好封存&#xff0c;以函数的形式&#xff0c;保存下来&#xff0c;然后直接导入进行使用&#xff0c;这样就可以读取文件&#xff0c;…

一组数字中算出最相近的组合_据说在金字塔里发现的这组数字,貌似是通往宇宙的密码...

我们都知道阿拉伯数字是全世界都在用的计数单位的数字&#xff0c;我们的生活离不开阿拉伯数字&#xff0c;其广泛性很大。比如买菜、买衣服。做数学题等等都需要用到。不过呢早前有人称在埃及金字塔内发现了一组数字142857&#xff0c;这组数字貌似就是通往宇宙的密码。这一说…

前端悬浮窗效果_Flutter自绘组件:微信悬浮窗(一)

看微信公众号的时候时常会想退出去回复消息&#xff0c;但又不想放弃已经阅读一半的文章&#xff0c;因为回复信息后再从公众号找到该篇文章之间有不必要的时间花费&#xff0c;微信悬浮窗的出现解决了这个烦恼&#xff0c;回复完消息之后只需要点击悬浮窗就可以回到之前在阅读…

python程序设计论文_【程序设计论文】程序设计论文范文(共40篇)

发表于&#xff1a;2020/10/20 11:53:15  点击数&#xff1a;77次 微信小程序开发课程改革实践 &#xff3b;摘要&#xff3d;微信小程序由于具有不同于传统移动APP的诸多优点&#xff0c;自推出以来得到了业界的广泛关注&#xff0c;计算机类专业人才培养过程要适应市场变化…

python数据类型总结_Python 数据类型总结

感觉新学点什么总要写下来&#xff0c;否则总有一种记不住的感觉 数据类型 python 中的变量定义就是赋值语句比如 val1 25 val2 "hehe" 类型转换函数 int()转换成整数 float()转换成浮点数 str()转换成字符串 complex(x)将x转为复数&#xff0c;x为实部&#xff0c…

python分箱分类代码_Python实现变量分箱及应用

之前发的内容里&#xff0c;代码看不清&#xff0c;此篇为重发。 个人观点&#xff0c;信贷行业中&#xff0c;模型稳定性往往比模型效果更重要。信贷行业所做的任何规则、政策、模型的调整&#xff0c;都需要较长时间才能知道结果如何&#xff0c;模型迭代周期相较于其他行业可…

date类型_Quartz与Date---cron的相互转换

产生原因:因为项目最近设计到了一个Quartz相关的模块&#xff0c;前端需要传递时间参数到后台, 然后后台设置一个新的定时任务, 所以后台需要一个可以实现Date与cron之间的相互转换(因为Quartz需要的Cron格式的数据)&#xff0c;所以就借助java的SimpleDateFormat的格式化,然后…

vbs if 不等于_6、if语句和关系表达式

示例3.1&#xff1a;星星公司致力于信件快递业务&#xff0c;收费标准是&#xff1a;500g以内6元&#xff0c;超过500g9元。应该就是输入重量&#xff0c;显示钱&#xff0c;那可以用cout和cin&#xff0c;如果w小于500&#xff0c;c是6&#xff0c;否则&#xff0c;c是9。//pr…

python函数定义和调用_函数定义和调用

定义函数 在JavaScript中&#xff0c;定义函数的方式如下&#xff1a; function abs(x) { if (x > 0) { return x; } else { return -x; } } 上述abs()函数的定义如下&#xff1a; function指出这是一个函数定义&#xff1b; abs是函数的名称&#xff1b; (x)括号内列出函数…

python文件是怎么写_python头文件怎么写

本文主要以python2为例。首先介绍一下Python头文件的编程风格&#xff0c;然后再给大家详细介绍import部分的基本用法。这两个部分就是Python中头文件的组成模块。编程风格#!/usr/bin/env python #在文件头部 ( 第一行 ) 加上 设置 Python 解释器 # -*- coding: utf-8 -*- #在文…

【学习笔记】第二章——处理机调度的概念、层次、时机、切换过程 调度方式、调度算法的指标

文章目录一. 概念 & 层次1. 高级调度&#xff08;作业调度&#xff09;2. 中级调度&#xff08;内存调度&#xff09;挂起态 & 七状态模型3. 低级调度&#xff08;进程调度&#xff09;4. 三种调度的对比联系 && 总结二. 时机、切换过程 & 调度方式1. 进程…

formdata上传文件_关于multipart/formdata上传文件

最近在做一个文件上传的开放接口&#xff0c;用到Content-Type: multipart/form-data这种请求类型&#xff0c;特地做了一些研究和记录。在最初的 http协议中&#xff0c;并没有上传文件方面的功能。RFC1867为 http协议添加了这个能力。常见的浏览器&#xff0c;如 Microsoft I…

【学习笔记】第二章——调度算法:先来先服务FCFS、短作业优先SJF、高响应比HRRN

文章目录一. 先来先服务&#xff08;FCFS&#xff09;二. 短作业优先&#xff08;SJF&#xff09;三. 高响应比优先1. 对前面两种算法的思考2. 描述四. 一、二、三总结例子都要手动写一遍哦&#xff5e;这三个是供早期的批处理系统使用的算法 一. 先来先服务&#xff08;FCFS&a…

python 最短路径算法_python Dijkstra算法实现最短路径问题的方法

本文借鉴于张广河教授主编的《数据结构》&#xff0c;对其中的代码进行了完善。 从某源点到其余各顶点的最短路径 Dijkstra算法可用于求解图中某源点到其余各顶点的最短路径。假设G&#xff5b;V&#xff0c;&#xff5b;E&#xff5d;&#xff5d;是含有n个顶点的有向图&#…

【学习笔记】第二章——时间片轮转RR、优先级调度、多级反馈队列调度算法

文章目录一. 时间片轮转二. 优先级调度三. 多级反馈队列调度算法四. 总结一. 时间片轮转 公平&#xff0c;轮流给进程提供时间片只用于进程调度&#xff08;只有进程才能被分配时间片&#xff09;抢占式&#xff0c;由时钟装置发出时钟中断来通知**缺点&#xff1a;**高频的进…