(1).学习的目标:
学会创建父子进程,并且能够区分当前进程是父还是子;了解父进程执行过程,子进程执行过程;能够用多进程执行任务
(2).相关函数学习:
(2.1)pcntl_fork()执行时:
如果当前的进程是父进程执行这个函数会返回创建成功的子进程的PID
如果当前的进程是子进程且第一次执行这个函数会返回0,第二次执行会返回创建成功的子进程PID
无论当前执行本函数的是父进程还是子进程,创建失败均返回-1
延伸:通过本函数的返回值我们可以认为,返回值-1是创建进程失败,大于0说明当前的进程是父进程,等于0说明当前的进程是子进程;本函数执行成功,底层会启动一个子进程从头开始再运行当前的脚本代码.
(2.2)cli_set_process_title()函数用于设置当前进程的标题,可以在终端查看
(2.3)pcntl_wait()函数内部通过挂起当前进程来等待子进程的状态.根据子进程的状态来决定父进程是否继续执行还是等待
例子:pcntl_wait($status)的意思是父进程必须等待一个子进程退出后,才能继续向下执行.pcntl_wait($status, WNOHANG);的是意思子进程没有退出父进程也可以继续向下执行。
(3).代码案例
(3.1).创建一个阻塞的子进程
<?php
//获取当前进程的Pid
$ppid = posix_getpid();
//创建子进程
$pid = pcntl_fork();
if ($pid == -1)
{
die ('创建子进程失败' . PHP_EOL);
}
elseif ($pid > 0)
{
cli_set_process_title("demo:我是父,我的id是{$ppid}");
sleep(30);
pcntl_wait($status);//父进程必须等待一个子进程退出后,才能继续走
}
else
{
$cpid = posix_getpid();
cli_set_process_title("demo:我是子,我的id是{$cpid}");
//子进程可以在这里执行部分任务
sleep(5);
}解析: 执行顺序为父进程创建子进程,父进程一直挂起在elseif代码区域等子进程执行完成再继续往下走,子进程执行完成,父进程结束
父进程的执行:
父进程调用pcntl_fork()创建了一个子进程,linux底层创建一个新的子进程让它重新跑一遍当前的代码(看子进程的执行说明)
父进程调用pcntl_fork()成功会返回一个大于0的子进程id,所以会执行到$pid>0代码区域,父进程发现pcntl_wait($status)代码让他等刚才创建的子进程把代码跑完他才能向下执行,于是父进程一直卡在这里睡觉等.
子进程的执行:
子进程调用pcntl_fork()创建子进程,一定是返回0,因为它自己就是子进程,所以没法再创建.$pid返回0则执行到子进程的代码区域,子进程sleep5秒后执行完成了.
父进程的执行:
刚才的父进程一直卡在父进程区域等子进程执行完成,现在子进程执行完成了,父进程继续向下执行,直到结束。
(3.2).循环创建多个非阻塞的子进程
for ($i = 0; $i < 3; $i++)
{
//创建子进程
$pid = pcntl_fork();
if ($pid == -1)
{
die ('创建子进程失败' . PHP_EOL);
}
elseif ($pid > 0)
{
cli_set_process_title("demo:我是父,我的id是{$ppid}");
pcntl_wait($status, WNOHANG); //我不管你子进程是否执行完成,我继续循环创建下一个子进程
}
else
{
$cpid = posix_getpid();
cli_set_process_title("demo:我是子,我的id是{$cpid}");
//可以在这里加上任务处理数据
sleep(10);
die();
}
}解析: 执行顺序为父进程创建完成3个子进程,然后父进程退出程序,剩下3个子进程在运行,每个子进程也只能循环1次,因为在循环中判断是子进程最后使用die结束了,为什么要加die?因为在上面的函数介绍中说明了子进程执行pcntl_fork函数第一次不会创建子进程,如果不die每个子进程还要循环3次,重复一堆子进程.
父进程的执行:
父进程调用pcntl_fork创建了一个子进程,底层创建一个新的子进程让它重新跑一遍当前的代码
父进程调用pcntl_fork()成功会返回一个大于0的子进程id,所以会执行到$pid>0代码区域,父进程发现pcntl_wait($status, WNOHANG)代码让他继续创建子进程,全部创建完成后父进程退出.
子进程的执行:
子进程调用pcntl_fork创建子进程,一定是返回0,因为它自己就是子进程,所以没法再创建.$pid返回0则执行到子进程的代码区域,子进程sleep5秒后会继续执行剩余的循环,所以这里在子进程加了die
其他:有人会问如果我需要子进程一直程序处理任务,但是这里die了子进程。这里使用die的目的是防止子进程继续循环创建重复的进程,如果想让子进程一直处理任务可以加while(true);上面的代码中使用sleep函数是为了程序多运行一会儿,方便在linux中看到进程的标题;
(1).创建数据库test ,创建表shop(字段id,total),商品id是1,商品总数10 (2).PHP模拟购买,商品数量大于0才能购买<?php //连接数据库 $con=mysqli_connect("192.168.2.18...
项目中使用服务来执行webservice,由于对方系统api不稳定,经常导致服务崩溃,只能重启,一个月差不多要重启一次。初期的解决办法是捕获异常,然后continue掉。<?php try { $url = 'http...
array_merge是最常用的数组合并方法,+号同样也可以,但是却有很大不同。array_merge遇到相同字符串key,后面数组的key会覆盖前面数组的key,+号正好相反。$a = [ 'one' => 'A on...
Redis提供了发布订阅功能,可以用于消息的传输,Redis的发布订阅机制包括三个部分,发布者(publisher),订阅者(subscriber)和频道(channel)。 发布者和订阅者都是Redis客户端,Channel则为Redis服务器端,发布者将消息发送到某个的频道,订阅了这个...
(1).学习目标: 了解常见信号类型(百度PHP支持的信号类型),(2).相关函数学习: (2.1).pcntl_signal函数用于设置一个信号管理器接收进程信号,参数1:信号类型,参数2:回调函数,用于在接收到参数1类型的信...
php7新增的特性(1).强制限制只能返回一种类型<?php class task { } //must return an integer function add(): int { &nb...