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(发邮件时,请将#更换为@)进行举报,并提供相关证据,一经查实,本站将立刻删除涉嫌侵权内容。