PHP 进程池与轮询调度算法实现多任务

进程的通信：

匿名管道，命名管道，消息队列，内存共享，socketpair 请自行撸代码测试哦

进程的调度算法：

轮询，随机分发，计分板等策略或是搞个优先极或是队列，或是堆栈等基本的算法【自己去发挥哦】

进程池：

撸过 tcp 的话应该知道要能处理多个客户端，就得用 IO 复用技术【事件多路分发器】或是多进程以及多线程，每来一个客户端就 fork 一个进程或是线程，那样的话上下文切换成本特别高，所以咱们先创建好一组进程【进程池】，等客户端连接上来的时候，通过某种算法【我们用的轮询】来选择某个进程投递任务来干活，这样的话就不用创建又销毁来回折腾了，提升它的效率。

下面是 PHP 代码版本的实现

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)
{
    
    return $instance->proc[$roll%$instance->processNum+1];
}
function master(&$instance)
{
    
    fprintf(STDOUT,"master 进程 %dn",$instance->processIdx);
    global $flag;
    $roll = 0;
    while ($flag){
 pcntl_signal_dispatch();
 
 $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 %dn",$instance->processIdx);
}
function getProcess(&$instance)
{
    
    return $instance->proc[$instance->processIdx];
}
function worker(&$instance)
{
    
    $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=%dn",posix_getpid(),$content,$file);
    }
    exit(0);
}
$instance = new instance();
processPool($instance,5);

效果

以上就是PHP 进程池与轮询调度算法实现多任务的详细内容，更多请关注考高分网其它相关文章！