PHP 进程池与轮询调度算法实现多任务的示例代码
phper请了解进程调度策略，CPU时间片，进程控制【创建，销毁，回收，进程信号】与及进程运行流程和基本的进程组，信号中断原理，以及进程之间的关系。
关于进程的更多内容可参考本人前面撸过的文章或是百度了解。
进程的通信：
匿名管道，命名管道，消息队列，内存共享，socketpair请自行撸代码测试哦
进程的调度算法：
轮询，随机分发，计分板等策略或是搞个优先极或是队列，或是堆栈等基本的算法【自己去发挥哦】
进程池：
撸过tcp的话应该知道要能处理多个客户端，就得用IO复用技术【事件多路分发器】或是多进程以及多线程，每来一个客户端就fork一个进程或是线程，那样的话上下文切换成本特别高，所以咱们先创建好一组进程【进程池】，等客户端连接上来的时候，通过某种算法【我们用的轮询】来选择某个进程投递任务来干活，这样的话就不用创建又销毁来回折腾了，提升它的效率。下面是PHP代码版本的实现
processIdx=0;
$instance->processNum=$num;
pcntl_signal(SIGINT,'sigHandler');
pcntl_signal(SIGTERM,'sigHandler');
$process=newprocess();
for($i=1;$i<=$num;$i++){
$instance->proc[$i]=clone$process;
$instance->proc[$i]->file=$i;
$instance->proc[$i]->pid=pcntl_fork();
$instance->processIdx=$i;
if($instance->proc[$i]->pid<0){
exit("进程创建失败");
}
elseif($instance->proc[$i]->pid>0){
//nothing
continue;
}else{
worker($instance);
}
}
master($instance);
$exitProcess=[];
while(1){
for($i=1;$i<=$num;$i++){
//非阻塞方式回收子进程
pcntl_waitpid($instance->proc[$i]->pid,$status,WNOHANG);
if($status){
$exitProcess[]=$instance->proc[$i]->pid;
fwrite(STDOUT,"worker#".$instance->proc[$i]->pid."-".$status,30);
}
}
if(count($exitProcess)==$instance->processNum){
exit(0);
}
usleep(1000);
}
}
//简单的轮询算法自己可以用队列，随机，链表，栈链，二叉树啥的折腾
functionroundRobin(&$instance,$roll)
{
/**@varinstance$instance*/
return$instance->proc[$roll%$instance->processNum+1];
}
functionmaster(&$instance)
{
/**@varinstance$instance*/
fprintf(STDOUT,"master进程%d\n",$instance->processIdx);
global$flag;
$roll=0;
while($flag){
pcntl_signal_dispatch();
/**@varprocess$process*/
$process=roundRobin($instance,$roll++);
echo"轮询的进程:".$process->pid.PHP_EOL;
$file=$process->file;
posix_mkfifo($file,0666);
$fd=fopen($file,"w");
fwrite($fd,"hi",2);
sleep(1);
}
for($i=1;$i<=$instance->processNum;$i++){
posix_kill($instance->proc[$i]->pid,9);
}
fprintf(STDOUT,"mastershutdown%d\n",$instance->processIdx);
}
functiongetProcess(&$instance)
{
/**@varinstance$instance*/
return$instance->proc[$instance->processIdx];
}
functionworker(&$instance)
{
/**@varprocess$process*/
$process=getProcess($instance);
while(1){
$file=$process->file;
posix_mkfifo($file,0666);
$fd=fopen($file,"r");
$content=fread($fd,10);
fprintf(STDOUT,"worker#%d读取的内容：%sfile=%d\n",posix_getpid(),$content,$file);
}
exit(0);
}
$instance=newinstance();
processPool($instance,5);
效果
以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持毛票票。
声明：本文内容来源于网络，版权归原作者所有，内容由互联网用户自发贡献自行上传，本网站不拥有所有权，未作人工编辑处理，也不承担相关法律责任。如果您发现有涉嫌版权的内容，欢迎发送邮件至：czq8825#qq.com（发邮件时，请将#更换为@）进行举报，并提供相关证据，一经查实，本站将立刻删除涉嫌侵权内容。