分享PHP-pcntl 实现多进程代码
PHP使用PCNTL系列的函数也能做到多进程处理一个事务。比如我需要从数据库中获取80w条的数据，再做一系列后续的处理，这个时候，用单进程？你可以等到明年今天了。。。所以应该使用pcntl函数了。
下面我们来看个实例
代码
<?php
$arChildId = array();
for($i = 0; $i < 10; $i++)
{
$iPid = pcntl_fork();
if($iPid == -1)
{
die('can\'t be forked.');
}
if($iPid)
{
# 主进程逻辑
$arChildId[] = $iPid;
}
else
{
# 子进程逻辑
$iPid = posix_getpid(); # 获取子进程的ID
$iSeconds = rand(5, 30);
echo '* Process '. $iPid. ' was created, and Executed, and Sleep '. $iSeconds. PHP_EOL;
excuteProcess($iPid, $iSeconds);
exit();
}
}
while(count($arChildId) > 0)
{
foreach($arChildId as $iKey=> $iPid)
{
$res = pcntl_waitpid($iPid, $status, WNOHANG);
if($res == -1 || $res > 0)
{
unset($arChildId[$iKey]);
echo '* Sub process: '. $iPid. ' exited with '. $status. PHP_EOL;
}
}
}
# 子进程执行的逻辑
function excuteProcess($iPid, $iSeconds)
{
file_put_contents('./log/'.$iPid.'.log', $iPid.PHP_EOL, FILE_APPEND);
sleep($iSeconds);
}
?>
运行结果
* Process 16163 was created, and Executed, and Sleep 11 * Process 16164 was created, and Executed, and Sleep 21 * Process 16165 was created, and Executed, and Sleep 24 * Process 16166 was created, and Executed, and Sleep 27 * Process 16167 was created, and Executed, and Sleep 8 * Process 16168 was created, and Executed, and Sleep 14 * Process 16169 was created, and Executed, and Sleep 14 * Process 16170 was created, and Executed, and Sleep 26 * Process 16171 was created, and Executed, and Sleep 20 * Process 16172 was created, and Executed, and Sleep 21 * Sub process: 16167 exited with 0 * Sub process: 16163 exited with 0 * Sub process: 16169 exited with 0 * Sub process: 16168 exited with 0 * Sub process: 16171 exited with 0 * Sub process: 16164 exited with 0 * Sub process: 16172 exited with 0 * Sub process: 16165 exited with 0 * Sub process: 16170 exited with 0 * Sub process: 16166 exited with 0
相关推荐
-
PHP多进程编程之僵尸进程问题的理解
PHP多进程编程之僵尸进程问题的理解 使用pcntl_fork函数可以让PHP实现多进程并发或者异步处理的效果:http://www.jb51.net/article/125789.htm 那么问题是我们产生的进程需要去控制,而不能置之不理.最基本的方式就是fork进程和杀死进程. 通过利用pcntl_fork函数,我们已经有了新的子进程,而子进程接下来完成我们需要处理的内容,那么我们就暂且叫做service()吧,而且我们需要很多个service()进行处理,再次参照我们之前的需求,父进程需要
-
PHP并发多进程处理利器Gearman使用介绍
工作中我们有时候会遇到比如需要同时发布数据到多个个服务器上,或者同时处理多个任务.可以使用PHP的curl_multi的方式并发处理请求,但是由于网络和数据以及各个服务器等等的一些情况导致这种并发处理的响应时间很慢,因为在并发请求的过程中还包括记录日志,处理数据等逻辑,等待处理结果并返回,所以也不能友好的满足后台操作的体验. 现在有另外一种方案,利Gearman来实现并发的需求.通过Client将请求发送到Gearman的Jobs,在每个Work中来再来进行curl_multi和数据处理和日志等
-
PHP多进程编程总结(推荐)
1. 准备 在动手之前,请确定你用的不是M$ Windows平台(因为我没有Windows).Linux / BSD / Unix应该都是没问题的.确认好了工作环境以后一起来看看我们需要的PHP模块是否都有.打开终端输入下面的命令: $ php -m 这个命令检查并打印当前PHP所有开启的扩展,看一下pcntl和posix是否在输出的列表中. 1.1. pcntl 如果找不到pcntl,八成是编译的时候没把这个扩展编译进去.如果你和我一样是编译安装的PHP,那么需要重新编译安装PHP.在配置的时
-
PHP多进程之pcntl_fork的实例详解
PHP多进程编之pcntl_fork的实例详解 其实PHP是支持并发的,只是平时很少使用而已.平时使用最多的应该是使用PHP-FMP调度php进程了吧. 但是,PHP的使用并不局限于做Web,我们完全也可以使用PHP来进行系统工具类的编程,做监控或者是运维.在使用这些方向的时候,我们可以使用到PHP的更多特性,例如并发(多进程).socket编程等. 那么接下来就说说我遇到的PHP多进程的编程.这个多进程的使用是有一个背景的,下面模糊描述一下背景. 我需要一个监控系统,当然使用PHP语言,监控系
-
PHP基于文件锁解决多进程同时读写一个文件问题示例
本文实例讲述了PHP基于文件锁解决多进程同时读写一个文件问题.分享给大家供大家参考,具体如下: 首先PHP是支持进程的而不支持多线程(这个先搞清楚了),如果是对于文件操作,其实你只需要给文件加锁就能解决,不需要其它操作,PHP的flock已经帮你搞定了. 用flock在写文件前先锁上,等写完后解锁,这样就实现了多线程同时读写一个文件避免冲突.大概就是下面这个流程 /* *flock(file,lock,block) *file 必需,规定要锁定或释放的已打开的文件 *lock 必需.规定要使用哪
-
PHP多进程编程实例详解
本文实例讲述了PHP多进程编程.分享给大家供大家参考,具体如下: 第一步: $ php -m 命令查看php是否安装pcntl 和 posix扩展,若没有则安装 使用场景: 1. 要进行大量的网络耗时的操作 2. 要做大量的运算,并且,系统有多个cpu,为了让用户有更快的体验,把一个任务,分成几个小任务,最后合并. 多进程常用函数: pcntl_alarm - 为进程设置一个alarm闹钟信号 pcntl_errno - 别名 pcntl_strerror pcntl_exec - 在当前进程
-
以实例全面讲解PHP中多进程编程的相关函数的使用
PHP有一组进程控制函数(编译时需要–enable-pcntl与posix扩展),使得php能实现跟c一样的创建子进程.使用exec函数执行程序.处理信号等功能. <?php header('content-type:text/html;charset=utf-8' ); // 必须加载扩展 if (!function_exists("pcntl_fork")) { die("pcntl extention is must !"); } //总进程的数量 $t
-
php分享朋友圈的实现代码
本文实例为大家分享了php实现分享朋友圈的具体代码,供大家参考,具体内容如下 <?php class JSSDK { private $appId; private $appSecret; public function __construct($appId, $appSecret) { $this->appId = $appId; $this->appSecret = $appSecret; } public function getSignPackage() { $jsapiTick
-
微信公众号网页分享功能开发的示例代码
现在每天都可以看到很多微信分享的链接上面有网站或者商家的自定义的分享标题,和分享链接的描述及分享出去的图像,例如下面的分享出去的链接: 上面这个是微信的js-SDK页面分享给微信好友在聊天列表中显示的视觉效果. 微信JS-SDK Demo :这个是微信网页分享出去的标题. 微信JS-SDK,帮助第三方为用户提供更优质的移动web服务:这个是被分享的这个页面的分享描述. 微信图标:这个就是自己网站或者自己自定义的图像. 上面这个是微信官方网页分享出去的定义描述,那么怎样实现自己网站网页的自定义分享
-
分享令人目瞪口呆的 Java 代码技巧
技术点 本文不是一个吹嘘的文章,不会讲很多高深的架构,相反,会讲解很多基础的问题和写法问题,如果读者自认为基础问题和写法问题都是不是问题,那请忽略这篇文章,节省出时间去做一些有意义的事情. 基于 Spring Boot + MyBatis Plus + Vue & Element 实现的后台管理系统 + 用户小程序,支持 RBAC 动态权限.多租户.数据权限.工作流.三方登录.支付.短信.商城等功能. 项目地址:https://github.com/YunaiV/ruoyi-vue-pro 开发
-
分享PHP-pcntl 实现多进程代码
PHP使用PCNTL系列的函数也能做到多进程处理一个事务.比如我需要从数据库中获取80w条的数据,再做一系列后续的处理,这个时候,用单进程?你可以等到明年今天了...所以应该使用pcntl函数了. 下面我们来看个实例 代码 <?php $arChildId = array(); for($i = 0; $i < 10; $i++) { $iPid = pcntl_fork(); if($iPid == -1) { die('can\'t be forked.'); } if($iPid) {
-
微信JS-SDK分享功能的.Net实现代码
JS-SDK接口是什么? 为了方便开发者实现微信内的网页(基于微信浏览器访问的网页)功能,比如拍照.选图.语音.位置等手机系统的能力,并方便开发者直接使用微信分享.扫一扫等微信特有的能力,微信推出了JS-SDK的整体开发包,供开发者方便使用. 分享功能 官方文档里提供了php.java.node.js以及python的示例代码,唯独没有c#版的,为了弥补广大.net用户的需求,我把php版本的示例代码逻辑照搬成了.net版,并在网页前端中加入了分享功能,希望对大家有用. 程序实现 流程图 程序里
-
分享8个最佳的代码片段在线测试网站
有时候,我们需要测试一些代码片段,而电脑中没有安装针对该语言的运行环境,没关系,你可以在线测试它们. 本文为你带来 8 款非常好用的代码片段在线工具,帮助你快速.方便地测试.编辑代码片段. 1. ideone ideone 是一个在线代码编辑.调试工具,允许开发者在线编译.运行代码,支持超过 40 种编程语言. 2. Codepad Codepad 是一个在线编译/解释器,还是一个简单的协作工具.在文本框中粘贴代码片段,Codepad 将会运行它,并会生成一个短 URL,你可以共享给其他
-
分享javascript、jquery实用代码段
本文实例为大家简单分享javascript.jquery实用demo,供大家参考,具体内容如下 javascript判断H5页面离开 function onbeforeunloadFn(){ console.log('离开页面'); //...code } function showOnbeforeunload(flags){ if(flags){ document.body.onbeforeunload = onbeforeunloadFn; }else{ document.body.onbe
-
Android 分享控件的实现代码
如今很多应用都提供向外分享信息的功能,在进行分享操作时,一般是从屏幕底部弹出所有具备分享功能的应用列表,再由用户进行选择 现在我就来模仿实现这种效果,不仅使分享控件从屏幕底部弹出,还要使分享控件能够上下拖动,这就需要使用到 design 包提供的 BottomSheetDialog 控件了 首先,声明 BottomSheetDialog 对话框的主布局 dialog_bottom_sheet.xml 当中,RecyclerView 用于展示提供分享功能的应用列表 <?xml version=&quo
-
python实现多进程代码示例
想要充分利用多核CPU资源,Python中大部分情况下都需要使用多进程,Python中提供了multiprocessing这个包实现多进程.multiprocessing支持子进程.进程间的同步与通信,提供了Process.Queue.Pipe.Lock等组件. 开辟子进程 multiprocessing中提供了Process类来生成进程实例 Process([group [, target [, name [, args [, kwargs]]]]]) group分组,实际上不使用 targe
-
python实现的生成随机迷宫算法核心代码分享（含游戏完整代码）
完整代码下载:http://xiazai.jb51.net/201407/tools/python-migong.rar 最近研究了下迷宫的生成算法,然后做了个简单的在线迷宫游戏.游戏地址和对应的开源项目地址可以通过上面的链接找到.开源项目中没有包含服务端的代码,因为服务端的代码实在太简单了.下面将简单的介绍下随机迷宫的生成算法.一旦理解后你会发现这个算法到底有多简单. 1.将迷宫地图分成多个房间,每个房间都有四面墙. 2.让"人"从地图任意一点A出发,开始在迷宫里游荡.从A房间的1/