php:多进程执行任务

starsfun 发布于2019-07-01 10:16 / 1280人阅读

摘要：此时可能有子进程继续执行。成功时，在父进程执行线程内返回产生的子进程的，在子进程执行线程内返回。函数刮起当前进程的执行直到一个子进程退出或接收到一个信号要求中断当前进程或调用一个信号处理函数。

需求

对指定数量的多个任务并发执行，并控制进程数

进程&线程：

进程间相互独立，不影响。

代码示例：

= $processNumLimit) {
           echo "wait chl start！
";
           $exitid = pcntl_wait($status); //等待退出
           echo "wait chl end！extid:",$exitid,"	status:",$status,"
";
       }
       
       //任务总量控制
       if($task >= $taskNum) {
           echo "taskNum enough！
";
           break;
       }
   }
   //processid=0为新创建的进程
   else{
       //模拟不同任务的不同执行时长
       $sleep = rand(1, 5);

       $currentProcessid = posix_getpid(); //当前进程的Id
       $parentProcessid = posix_getppid(); // 父级进程的ID
       $phpProcessid = getmypid(); //当前php进程的id
       echo "task:",$task,"	processid:",$processid,"	currentProcessid:",$currentProcessid,"	parentProcessid:",$parentProcessid,"	phpProcessid:",$phpProcessid,"	sleep:",$sleep,"	begin!
";

       sleep($sleep);

       echo "task:",$task,"	processid:",$processid,"	currentProcessid:",$currentProcessid,"	parentProcessid:",$parentProcessid,"	phpProcessid:",$phpProcessid,"	sleep:",$sleep,"	end!
";
       
       exit(0); //子进程执行完后退出，防止进入循环创建子进程
   }
}

执行的结果：

task:1    processid:32225    currentProcessid:32224    parentProcessid:15053    phpProcessid:32224
task:0    processid:0    currentProcessid:32225    parentProcessid:32224    phpProcessid:32225    sleep:5    begin!
task:2    processid:32226    currentProcessid:32224    parentProcessid:15053    phpProcessid:32224
wait chl start！
task:1    processid:0    currentProcessid:32226    parentProcessid:32224    phpProcessid:32226    sleep:2    begin!
task:1    processid:0    currentProcessid:32226    parentProcessid:32224    phpProcessid:32226    sleep:2    end!
wait chl end！extid:32226    status:0
task:3    processid:32228    currentProcessid:32224    parentProcessid:15053    phpProcessid:32224
wait chl start！
task:2    processid:0    currentProcessid:32228    parentProcessid:32224    phpProcessid:32228    sleep:1    begin!
task:2    processid:0    currentProcessid:32228    parentProcessid:32224    phpProcessid:32228    sleep:1    end!
wait chl end！extid:32228    status:0
task:4    processid:32229    currentProcessid:32224    parentProcessid:15053    phpProcessid:32224
wait chl start！
task:3    processid:0    currentProcessid:32229    parentProcessid:32224    phpProcessid:32229    sleep:2    begin!
task:0    processid:0    currentProcessid:32225    parentProcessid:32224    phpProcessid:32225    sleep:5    end!
wait chl end！extid:32225    status:0
task:5    processid:32270    currentProcessid:32224    parentProcessid:15053    phpProcessid:32224
wait chl start！
task:4    processid:0    currentProcessid:32270    parentProcessid:32224    phpProcessid:32270    sleep:1    begin!
task:3    processid:0    currentProcessid:32229    parentProcessid:32224    phpProcessid:32229    sleep:2    end!
wait chl end！extid:32229    status:0
task:6    processid:32271    currentProcessid:32224    parentProcessid:15053    phpProcessid:32224
wait chl start！
task:5    processid:0    currentProcessid:32271    parentProcessid:32224    phpProcessid:32271    sleep:4    begin!
task:4    processid:0    currentProcessid:32270    parentProcessid:32224    phpProcessid:32270    sleep:1    end!
wait chl end！extid:32270    status:0
task:7    processid:32273    currentProcessid:32224    parentProcessid:15053    phpProcessid:32224
wait chl start！
task:6    processid:0    currentProcessid:32273    parentProcessid:32224    phpProcessid:32273    sleep:1    begin!
task:6    processid:0    currentProcessid:32273    parentProcessid:32224    phpProcessid:32273    sleep:1    end!
wait chl end！extid:32273    status:0
task:8    processid:32274    currentProcessid:32224    parentProcessid:15053    phpProcessid:32224
wait chl start！
task:7    processid:0    currentProcessid:32274    parentProcessid:32224    phpProcessid:32274    sleep:2    begin!
task:5    processid:0    currentProcessid:32271    parentProcessid:32224    phpProcessid:32271    sleep:4    end!
task:7    processid:0    currentProcessid:32274    parentProcessid:32224    phpProcessid:32274    sleep:2    end!
wait chl end！extid:32274    status:0
task:9    processid:32277    currentProcessid:32224    parentProcessid:15053    phpProcessid:32224
wait chl start！
wait chl end！extid:32271    status:0
task:8    processid:0    currentProcessid:32277    parentProcessid:32224    phpProcessid:32277    sleep:2    begin!
task:10    processid:32278    currentProcessid:32224    parentProcessid:15053    phpProcessid:32224
wait chl start！
task:9    processid:0    currentProcessid:32278    parentProcessid:32224    phpProcessid:32278    sleep:2    begin!
task:8    processid:0    currentProcessid:32277    parentProcessid:32224    phpProcessid:32277    sleep:2    end!
task:9    processid:0    currentProcessid:32278    parentProcessid:32224    phpProcessid:32278    sleep:2    end!
wait chl end！extid:32277    status:0
taskNum enough

执行分析：

在pcntl_fork出创建子进程后，子进程执行功能代码，父进程继续递增任务id，创建下一个任务进程；

通过pcntl_wait等待有子进程执行完毕退出后，再新创建进程，实现进程总数的控制；

在主进程完成创建后，通过break退出循环。此时可能有子进程继续执行。

相关函数： pcntl_fork

在当前进程当前位置产生分支（子进程）。成功时，在父进程执行线程内返回产生的子进程的PID，在子进程执行线程内返回0。失败时，在 父进程上下文返回-1，不会创建子进程，并且会引发一个PHP错误。

pcntl_wait

等待或返回fork的子进程状态。wait函数刮起当前进程的执行直到一个子进程退出或接收到一个信号要求中断当前进程或调用一个信号处理函数。 如果一个子进程在调用此函数时已经退出（俗称僵尸进程），此函数立刻返回。子进程使用的所有系统资源将 被释放。

其他：

1.僵尸进程及孤儿进程的问题

部分僵尸进程被pcntl_wait获取状态并释放资源，未接管的进程在主进程退出后成为孤儿进程。孤儿进程被init进程收养，完成wait的状态获取和资源释放。

混合云 idc机房托管 php定时执行任务任务计划执行php php多进程 php多进程编程

文章版权归作者所有，未经允许请勿转载,若此文章存在违规行为，您可以联系管理员删除。

转载请注明本文地址：https://www.ucloud.cn/yun/28981.html

PHP 命令行方式实现异步多进程模式的任务处理

摘要：定义任务处理方法。读取来自命令行的参数，开始执行任务。该函数有两个参数和，是引用类型，用来存储子进程的状态，有两个可选常量，分别表示不等待子进程结束立即返回和等待子进程结束。用PHP来实现异步任务一直是个难题，现有的解决方案中：PHP知名的异步框架有 swoole 和 Workerman，但都是无法在 web 环境中直接使用的，即便强行搭建 web 环境，异步调用也是使用多进程模式实...

Invoker 2019-07-01 11:15 评论0 收藏0
PHP下的异步尝试二：初识协程

摘要：如果仅依靠程序自动交出控制的话，那么一些恶意程序将会很容易占用全部时间而不与其他任务共享。多个操作可以在重叠的时间段内进行。 PHP下的异步尝试系列如果你还不太了解PHP下的生成器，你可以根据下面目录翻阅 PHP下的异步尝试一：初识生成器 PHP下的异步尝试二：初识协程 PHP下的异步尝试三：协程的PHP版thunkify自动执行器 PHP下的异步尝试四：PHP版的Promise ...

MudOnTire 2019-07-01 10:44 评论0 收藏0
PHP 进程的实现与管理

摘要：运行模式实现进程前，需了解常见的的运行模式通用网关接口模式模式命令行模式模块模式作为服务器模块而进程则是使用命令行模式运行的基本实现中提供了一个扩展，可以利用操作系统的调用来实现多进程。应用场景一些耗时任务：大数据表分表后的统计信息功能分批发送短信或邮件功能其他可分目标的任务功能（很多种）所以我们就需要一个常驻内存的任务管理工具，为了保证实时性，一方面我们让它一直执行任...

MockingBird 2019-07-01 12:26 评论0 收藏0
PHP 进程的实现与管理

摘要：运行模式实现进程前，需了解常见的的运行模式通用网关接口模式模式命令行模式模块模式作为服务器模块而进程则是使用命令行模式运行的基本实现中提供了一个扩展，可以利用操作系统的调用来实现多进程。应用场景一些耗时任务：大数据表分表后的统计信息功能分批发送短信或邮件功能其他可分目标的任务功能（很多种）所以我们就需要一个常驻内存的任务管理工具，为了保证实时性，一方面我们让它一直执行任...

testbird 2019-07-25 14:17 评论0 收藏0
PHP 进程的实现与管理

摘要：运行模式实现进程前，需了解常见的的运行模式通用网关接口模式模式命令行模式模块模式作为服务器模块而进程则是使用命令行模式运行的基本实现中提供了一个扩展，可以利用操作系统的调用来实现多进程。应用场景一些耗时任务：大数据表分表后的统计信息功能分批发送短信或邮件功能其他可分目标的任务功能（很多种）所以我们就需要一个常驻内存的任务管理工具，为了保证实时性，一方面我们让它一直执行任...

Michael_Lin 2019-06-21 15:22 评论0 收藏0
PHP多进程初探 --- 利用多进程开发点儿东西吧

摘要：主进程退出子进程继续执行给进程重新起个名字加入我们出个子进程就可以搞定这些任务，那么出个子进程，同时父进程要负责这个子进程的状态等。 [原文地址：https://blog.ti-node.com/blog...] 干巴巴地叨逼叨了这么久，时候表演真正的技术了！做个高端点儿的玩意吧，加入我们要做一个任务系统，这个系统可以在后台帮我们完成一大波（注意是一大波）数据的处理，那么我们自然想到...

huaixiaoz 2019-07-01 10:36 评论0 收藏0