php foreach 收邮件_php机制本身不提供多线程的操作,有了swoole就不一样了

eee0e7fc300f5f2ff41ff93c8c064dcc.png

多个任务同时执行

比如,我们要对已知的用户数据进行判断,是否需要发送邮件和短信,如果需要发送则发送。

不使用多进程时,我们首先判断是否发送邮件,如果需要则发送;然后再判断是否需要发送短信,如果需要则发送。如果发送邮件耗时2s,发送短信耗时2s,那么我们完成任务大概需要4s左右的时间。

如果我们使用多线程的话,可以开两个线程,一个用于处理邮件,一个用于处理短信,则耗时一共需要2s左右,处理时间缩短了一半。

以下是代码实例:

<?php
/*** Created by PhpStorm.* User: cyw0413* Date: 2018/10/20* Time: 10:37*/
$info = array("sendmail"=>1,"mailto"=>"12345@qq.com","sendsms"=>1,"smsto"=>"123456"
);
echo "start:".date("Y-m-d H:i:s").PHP_EOL;
$mail_process = new swoole_process('sendMail',true);
$mail_process->start();
$sms_process = new swoole_process('sendSMS',true);
$sms_process->start();
//主进程输出子进程范围内容
echo $mail_process->read();
echo PHP_EOL;
echo $sms_process->read();
echo PHP_EOL;
echo "end:".date("Y-m-d H:i:s").PHP_EOL;
//并行函数
function sendMail(swoole_process $worker){global $info;if($info['sendmail']==1){sleep(2);$worker->write("send mail to ".$info['mailto']);}
}
function sendSMS(swoole_process $worker){global $info;if($info['sendmail']==1){sleep(2);$worker->write("send sms to ".$info['smsto']);}
}

d8f83a4e51037d4934615b753cb104f4.png

大任务划分成多个小任务

假设我们现在有一个通过curl抓取网页内容的需求,需要抓取10个网页,url地址通过数组读取,每个curl耗时2s。如果我们通过for循环来抓取这10个网页,需要耗时20s,使用多进程我们可以将任务划分成5份,分别由5个进程执行,每个进程抓取2个url,并发执行,共耗时4s,效率提高5倍。

以下是代码实例

<?php
/*** Created by PhpStorm.* User: cyw0413* Date: 2018/10/20* Time: 10:51*/
$url_arr = array();
for ($i=0;$i<10;$i++){$url_arr[] = "www.baidu.com?wd=".$i;
}
echo "start:".date("Y-m-d H:i:s").PHP_EOL;
$workers = array();
for ($i=0;$i<5;$i++){$process = new swoole_process('getContents',true);$process->start();$process->write($i);$workers[] = $process;
}
//主进程数据结果
foreach ($workers as $process){echo $process->read();echo PHP_EOL;
}
echo "end:".date("Y-m-d H:i:s").PHP_EOL;
function getContents(swoole_process $worker){$i = $worker->read();global $url_arr;$res1 = execCurl($url_arr[($i*2)]);$res2 = execCurl($url_arr[($i*2+1)]);echo $res1.PHP_EOL.$res2;
}
function execCurl($url){sleep(2);return "handle ".$url." finished";
}

2b89a29958e2f75ce37c2b9b5809ffb5.png

总结

以上两种情况,本质上都是将逻辑上没有先后关系的任务,用多个进程程并发执行,提高效率。

php机制本身不提供多线程的操作,ptcl扩展提供了php操作linux多进程的接口。

点关注,不迷路

好了各位,以上就是这篇文章的全部内容了,能看到这里的人呀,都是人才。之前说过,PHP方面的技术点很多,也是因为太多了,实在是写不过来,写过来了大家也不会看的太多,所以我这里把它整理成了PDF和文档,如果有需要的可以

点击进入暗号: PHP+「平台」

14db7025975c4392e97f8b4d38e27a2d.png

1be72ff55b9d65caf33a145faf3e23ff.png

更多学习内容可以访问

阿布阿布:【对标大厂】精品PHP架构师教程目录大全,只要你能看完保证薪资上升一个台阶(持续更新)​​zhuanlan.zhihu.com
4047b112ce4c2fea2daf655fed86f12e.png

以上内容希望帮助到大家,很多PHPer在进阶的时候总会遇到一些问题和瓶颈,业务代码写多了没有方向感,不知道该从那里入手去提升,对此我整理了一些资料,包括但不限于:分布式架构、高可扩展、高性能、高并发、服务器性能调优、TP6,laravel,YII2,Redis,Swoole、Swoft、Kafka、Mysql优化、shell脚本、Docker、微服务、Nginx等多个知识点高级进阶干货需要的可以免费分享给大家,需要的可以加入我的 PHP技术交流群

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

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

相关文章

C#中的interface

接口&#xff08;interface&#xff09; 接口泛指实体把自己提供给外界的一种抽象化物&#xff08;可以为另一实体&#xff09;&#xff0c;用以由内部操作分离出外部沟通方法&#xff0c;使其能被修改内部而不影响外界其他实体与其交互的方式。 接口实际上是一个约定: 如&…

网易不进垃圾箱html,腾讯QQ、网易126、163邮箱发送邮件进入垃圾箱及收不到邮件怎么办?...

近期有用户反馈在云奇付(www.361ser.com)会员中心通过腾讯QQ邮箱、网易126、163邮箱绑定账号及安全验证无法正常收取或收不到云奇付发送的邮件怎么办&#xff1f;其实这是因为QQ邮箱、126邮箱、163邮箱等其它邮箱都有反垃圾邮件机制&#xff0c;很多企业网站的邮件都被误拦截到…

java技术分享主题_Java开发入门:适合新手练手的Java项目(附源码下载)

Java作为一门古老的语言&#xff0c;已有20年左右的历史&#xff0c;这在发展日新月异的技术圈可以说是一个神话。虽然不少人曾抱怨Java语言就像老太太的裹脚布&#xff0c;又臭又长&#xff0c;有时写了500行都不能表达程序员的意图。但从市场上的招聘现状看&#xff0c;Java工…

ehcache 缓存丢失_解决Ehcache缓存警告问题

警告: Creating a new instance of CacheManager using the diskStorePath "D:\Apache Tomcat 6.0.18\temp" which is already used by an existing CacheManager.The source of the configuration was classpath.The diskStore path for this CacheManager will be …

html简单父子页面,js 的 iframe 父子页面通信的简单方法

1、获取 子页面 的 window 对象在父页面中&#xff0c;存在如下两个对象window.framesdocument.iframeElement.contentWindow可以获取到 子页面 window 对象// iframe iddocument.getElementById(menuIframe).contentWindow// iframe namewindow.frames[menuIframe].window// i…

uni app 调用网络打印机_uni-app 的使用体验总结

[实践] uni-app 的使用总结最近使用 uni-app 的感受。使用体验没用之前以为真和 Vue 一样&#xff0c;用了之后才知道。有点类似 Vue 和 小程序结合的感觉。写类似小程序的标签&#xff0c;有着小程序和 Vue 的生命周期钩子。对比 uni-app 文档和微信小程序的文档&#xff0c;不…

iOS开发——高级篇——二维码的生产和读取

一、二维码的生成 从iOS7开始集成了二维码的生成和读取功能此前被广泛使用的zbarsdk目前不支持64位处理器 生成二维码的步骤&#xff1a;导入CoreImage框架通过滤镜CIFilter生成二维码 二维码的内容(传统的条形码只能放数字)&#xff1a;纯文本名片URL // 1. 实例化二维码滤镜 …

python 地址_python 解析地址 | 学步园

socekt.getaddrinfo的返回值介绍family: 表示socket使用的协议簇。常用的协议簇包括AF_UNIX(本机通信)/AF_INET(TCP/IP协议簇中的IPv4协议)/AF_INET6(TCP/IP协议簇中的IPv4协议)。在python的socket包中&#xff0c;用1表示AF_UNIX&#xff0c;2表示AF_INET&#xff0c;10表示AF…

html 微信发送给朋友,H5链接分享给微信好友,显示标题、描述、缩略图

效果展示image.png1.公众号设置1.1公众号需要经过认证&#xff0c;具有分享接口功能image.png1.2填写正确的域名(域名需要经过备案)image.png1.3 保存好AppID、AppSecret、设置好ip白名单(非常重要)image.png2.php代码(需要有php环境下&#xff0c;放到域名目录下)2.1展示下目录…

python怎么创建变量_python怎么创建变量

变量(variable)是学习python初始时&#xff0c;就会接触到的一个新的知识点&#xff0c;也是一个需要熟知的概念。python是一种动态类型语言&#xff0c;在赋值的执行中可以绑定不同类型的值&#xff0c;这个过程叫做变量赋值操作&#xff0c;赋值同时确定了变量类型。在python…

nginx 学习笔记【持续更新...】

1.如果在安装过程中出现以下错误 需要安装pcre库 解决方案&#xff1a;yum install pcre 2.如果nginx启动提示端口被占用,则停止该端口的服务再启动nginx,一般为httpd服务 解决方案&#xff1a;service httpd stop 3.nginx下php编译 ./configure --prefix/usr/local/fastphp …

python问号表达式_python中的问号表达式

我们知道C语句中存在问号表达式&#xff0c;例如下面&#xff1a;1a2>1? 10: -10;那么&#xff0c;Python脚本语言中是否也存在类似的问号表达式呢&#xff1f;答案是肯定的。而且存在两种方式。方式1&#xff1a;使用if else实现如下例&#xff1a;1b 5a 2 if b 4 else 1p…

计算机入门在线阅读,电脑入门基础教程..doc

PAGEPAGE 8大学计算机基础实验指导书A班2013年9月实验一 windows基本操作、系统环境一、实验目的1&#xff0e;熟悉Windows的基本知识和基本操作。2&#xff0e;熟悉Windows的程序管理。3&#xff0e;熟悉“Windows资源管理器”和“我的电脑”的使用。4&#xff0e;熟悉文件和文…

efcore 实体配置_创建并配置模型

创建并配置模型Creating and configuring a model10/13/2020本文内容Entity Framework 使用一组约定基于实体类的形状构建模型。Entity Framework uses a set of conventions to build a model based on the shape of your entity classes. 可指定其他配置以补充和/或替代约定的…

python怎么放音乐_python怎么播放音乐

Python播放音乐要使用pygame模块 首先安装pygame模块&#xff1a;pip install pygame 方法实现&#xff1a;def play_music(self): filepath r"E:\music\消愁.mp3"; pygame.mixer.init() # 加载音乐 pygame.mixer.music.load(filepath) pygame.mixer.music.play(sta…

sprintf_s与_snprintf与_snprintf_s

MSDN页面分别如下&#xff1a; spirntf_s: http://msdn.microsoft.com/zh-cn/library/ce3zzk1k%28VS.80%29.aspx _snprintf: http://msdn.microsoft.com/zh-cn/library/2ts7cx93%28vVS.90%29.aspx _snprintf_s: http://msdn.microsoft.com/zh-cn/library/f30dzcf6.aspx 三个页面…

git ssh配置文件 服务器_git登录ssh服务器

{"moduleinfo":{"card_count":[{"count_phone":1,"count":1}],"search_count":[{"count_phone":6,"count":6}]},"card":[{"des":"云服务器 ECS(Elastic Compute Service)是一…

怎么用计算机打分数,电脑excel中分数怎么打出来(图解excel分数输入法)

在日常工作中&#xff0c;我们经常需要在excel中输入分数&#xff0c;默认情况下&#xff0c;当我们直接输入分数&#xff0c;比如输入“9/16” 回车后&#xff0c;会发现系统显示的却是日期数据&#xff0c;如下图所示&#xff0c;那么分数该怎么输入呢&#xff1f;今天就来和…

python终止线程_Python里怎么终止一个线程

Python用sleep停止一个线程的运行&#xff0c;而不影响主线程的运行&#xff0c;案例代码如下&#xff1a; from threading import *import timeclass MyThread(Thread): def run (self): self.ifdo True; while self.ifdo: print I am running... time.sleep(2) def stop (se…

C#中的多线程

1简介及概念 C# 支持通过多线程并行执行代码&#xff0c;线程有其独立的执行路径&#xff0c;能够与其它线程同时执行。 一个 C# 客户端程序&#xff08;Console 命令行、WPF 以及 Windows Forms&#xff09;开始于一个单线程&#xff0c;这个线程&#xff08;也称为“主线程”…