phper 请了解进程调度策略，cpu 时间片，进程控制【创建，销毁，回收，进程信号】与及进程运行流程和基本的进程组，信号中断原理，以及进程之间的关系。
进程的通信：
匿名管道，命名管道，消息队列，内存共享，socketpair 请自行撸代码测试哦
进程的调度算法：
轮询，随机分发，计分板等策略或是搞个优先极或是队列，或是堆栈等基本的算法【自己去发挥哦】
进程池：
撸过 tcp 的话应该知道要能处理多个客户端，就得用 io 复用技术【事件多路分发器】或是多进程以及多线程，每来一个客户端就 fork 一个进程或是线程，那样的话上下文切换成本特别高，所以咱们先创建好一组进程【进程池】，等客户端连接上来的时候，通过某种算法【我们用的轮询】来选择某个进程投递任务来干活，这样的话就不用创建又销毁来回折腾了，提升它的效率。
下面是 php 代码版本的实现
<?php/** * created by phpstorm. * user: 1655664358@qq.com * date: 2019/1/12 * time: 16:18 */$flag = 1;class process{ public $pid; public $name; public $file; public $num;}class instance{ public $processidx; public $proc = []; public $processnum;}function sighandler($signo){ global $flag; $flag = 0; echo "信号中断处理".php_eol;}function processpool(instance &$instance,$num){ if (!$instance||$num==0){ fprintf(stderr,"%s","参数错误"); return 1; } $instance->processidx = 0; $instance->processnum = $num; pcntl_signal(sigint,'sighandler'); pcntl_signal(sigterm,'sighandler'); $process = new process(); 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("进程创建失败"); } else if ($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); }}//简单的轮询算法 自己可以用队列，随机，链表，栈链，二叉树啥的折腾function roundrobin(&$instance,$roll){ /** @var instance $instance */ return $instance->proc[$roll%$instance->processnum+1];}function master(&$instance){ /** @var instance $instance */ fprintf(stdout,"master 进程 %d\n",$instance->processidx); global $flag; $roll = 0; while ($flag){ pcntl_signal_dispatch(); /** @var process $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,"master shutdown %d\n",$instance->processidx);}function getprocess(&$instance){ /** @var instance $instance */ return $instance->proc[$instance->processidx];}function worker(&$instance){ /** @var process $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读取的内容：%s file=%d\n",posix_getpid(),$content,$file); } exit(0);}$instance = new instance();processpool($instance,5);
效果
以上就是php 进程池与轮询调度算法实现多任务的详细内容。