進(jìn)程的通信：

匿名管道，命名管道，消息隊(duì)列，內(nèi)存共享，socketpair 請(qǐng)自行擼代碼測(cè)試哦

進(jìn)程的調(diào)度算法：

輪詢，隨機(jī)分發(fā)，計(jì)分板等策略或是搞個(gè)優(yōu)先極或是隊(duì)列，或是堆棧等基本的算法【自己去發(fā)揮哦】

進(jìn)程池：

擼過(guò) tcp 的話應(yīng)該知道要能處理多個(gè)客戶端，就得用 IO 復(fù)用技術(shù)【事件多路分發(fā)器】或是多進(jìn)程以及多線程，每來(lái)一個(gè)客戶端就 fork 一個(gè)進(jìn)程或是線程，那樣的話上下文切換成本特別高，所以咱們先創(chuàng)建好一組進(jìn)程【進(jìn)程池】，等客戶端連接上來(lái)的時(shí)候，通過(guò)某種算法【我們用的輪詢】來(lái)選擇某個(gè)進(jìn)程投遞任務(wù)來(lái)干活，這樣的話就不用創(chuàng)建又銷(xiāo)毀來(lái)回折騰了，提升它的效率。

下面是 PHP 代碼版本的實(shí)現(xiàn)

<?php/** * Created by PhpStorm. * User: 1655664358@qq.com * Date: 2019/1/12 * Time: 16:18 */$flag = 1;html' target='_blank'>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 "信號(hào)中斷處理".PHP_EOL;}function processPool(instance &$instance,$num){    if (!$instance||$num==0){        fprintf(STDERR,"%s","參數(shù)錯(cuò)誤");        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("進(jìn)程創(chuàng)建失敗");        }        else if ($instance->proc[$i]->pid>0){            //nothing            continue;        }else{            worker($instance);        }    }    master($instance);    $exitProcess= [];    while (1){        for ($i=1;$i<=$num;$i++){        //非阻塞方式回收子進(jìn)程            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);    }}//簡(jiǎn)單的輪詢算法  自己可以用隊(duì)列，隨機(jī)，鏈表，棧鏈，二叉樹(shù)啥的折騰function roundRobin(&$instance,$roll){    /** @var instance $instance */    return $instance->proc[$roll%$instance->processNum+1];}function master(&$instance){    /** @var instance $instance */    fprintf(STDOUT,"master 進(jìn)程 %d/n",$instance->processIdx);    global $flag;    $roll = 0;    while ($flag){        pcntl_signal_dispatch();        /** @var process $process */        $process = roundRobin($instance,$roll++);        echo "輪詢的進(jìn)程:".$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讀取的內(nèi)容：%s file=%d/n",posix_getpid(),$content,$file);    }    exit(0);}$instance = new instance();processPool($instance,5);

效果

以上就是PHP 進(jìn)程池與輪詢調(diào)度算法實(shí)現(xiàn)多任務(wù)的詳細(xì)內(nèi)容，更多請(qǐng)關(guān)注 其它相關(guān)文章！

鄭重聲明：本文版權(quán)歸原作者所有，轉(zhuǎn)載文章僅為傳播更多信息之目的，如作者信息標(biāo)記有誤，請(qǐng)第一時(shí)間聯(lián)系我們修改或刪除，多謝。