13518219792
这篇文章给大家分享的是有关php如何使用多进程的内容。小编觉得挺实用的，因此分享给大家做个参考，一起跟随小编过来看看吧。
创新互联服务项目包括双滦网站建设、双滦网站制作、双滦网页制作以及双滦网络营销策划等。多年来，我们专注于互联网行业，利用自身积累的技术优势、行业经验、深度合作伙伴关系等，向广大中小型企业、政府机构等提供互联网行业的解决方案，双滦网站推广取得了明显的社会效益与经济效益。目前，我们服务的客户以成都为中心已经辐射到双滦省份的部分城市，未来相信会继续扩大服务区域并继续获得客户的支持与信任！
代码：
]>
*/
class process{
public $num = 10; # 进程数
public $timeout = 4; # 延迟时间
public $pipedir = "pipe/"; # 管道目录
public $logdir = "log/"; # 日志目录
public $errlog = "err.log"; # 错误日志
public $successlog = "success.log"; # 成功日志
/*
@desc：构造方法，创建相关目录，检察是否支持扩展
*/
public function __construct(){
$pipedir = $this->pipedir;
$logdir = $this->logdir;
if(!is_dir($pipedir)){
if(!mkdir($pipedir)){
$this->write_log(1,"创建管道目录{$pipedir}失败");
}
}
if(!is_dir($logdir)){
if(!mkdir($logdir)){
$this->write_log(1,"创建日志目录{$logdir}失败");
}
}
if (!function_exists('pcntl_fork')) {
$this->write_log(1,'未安装pcntl扩展');
exit;
}
}
/*
@desc：内部方法，写日志
@param type 日志类型 1错误日志 2成功日志
@param msg 日志消息
*/
private function write_log($type,$msg){
$logdir = $this->logdir;
$errlog = $this->errlog;
$successlog = $this->successlog;
$prelog = date('Y-m-d H:i:s')."：";
if($type == 1){
$logname = $logdir.$errlog;
}else{
$logname = $logdir.$successlog;
}
file_put_contents($logname,$prelog.$msg.PHP_EOL,FILE_APPEND);
}
/*
@desc：主方法，执行程序
@param name 执行命令的回调函数
*/
public function run($name){
$num = $this->num;
$timeout = $this->timeout;
$pipedir = $this->pipedir;
$pipefile = $pipedir.posix_getpid();
if (!posix_mkfifo($pipefile, 0666)) {
$this->write_log(1,"创建管道文件{$pipefile}失败");
exit;
}
# 处理任务
for ($i = 0; $i < $num; ++$i ) {
$cpid = pcntl_fork(); # 创建子进程
if ($cpid == 0) {
# 子进程过程
call_user_func($name,$i);
$pw = fopen($pipefile, 'w');
fwrite($pw, $i."\n"); # 当前任务处理完比，在管道中写入数据
fclose($pw);
exit(0); # 执行完后退出
}
}
# 父进程
$pr = fopen($pipefile, 'r');
stream_set_blocking($pr, FALSE); # 将管道设置为非堵塞，用于适应超时机制
$pdata = ''; # 存放管道中的数据
$sline = 0; # 成功执行的进程数量
$stime = time();
while ($sline < $num && (time() - $stime) < $timeout) {
$tline = fread($pr, 1024);
if (empty($tline)) {
continue;
}
# 用于分析多少任务处理完毕，通过'\n'标识
foreach(str_split($tline) as $v) {
if ("\n" == $v) {
++$sline;
}
}
$pdata .= $tline;
}
$this->write_log(2,"总共{$sline}个任务执行成功");
fclose($pr);
unlink($pipefile); # 删除管道，已经没有作用了
# 等待子进程执行完毕，避免僵尸进程
$n = 0;
while ($n < $num) {
$status = -1;
$cpid = pcntl_wait($status, WNOHANG);
if ($cpid > 0) {
$this->write_log(2,"进程{$cpid}执行结束");
++$n;
}
}
# 验证结果，主要查看结果中是否每个任务都完成了
$arr = array();
foreach(explode("\n", $pdata) as $i) {
if (is_numeric(trim($i))) {
array_push($arr, $i);
}
}
$arr = array_unique($arr);
if ( count($arr) == $num) {
$this->write_log(2,var_export($arr,true));
} else {
$this->write_log(1,"执行成功数量：".count($arr));
$this->write_log(1,"执行成功的线程：".var_export($arr,true));
}
}
}测试：
$process = new process();
$process->num = 5; # 修改进程数为5
$process->run('todo');
/*
@desc：真实处理业务的方法
@param pid 进程id
*/
function todo($pid){
$num = 19; # 总任务数
$anum = ceil($num/5); # 平均每个进程处理任务数
$lnum = $num - $anum*(5-1); # 最后一个进程处理任务数
$minnum = $anum*$pid; # 当前进程处理的最小值
$maxnum; # 当前进程处理的最大值
if($pid<(5-1)){
$maxnum = $minnum + $anum;
}else{
$maxnum = $num;
}
for($i=$minnum;$i<$maxnum;$i++){
echo "进程号：{$pid}；输出：{$i}".PHP_EOL;
}
}输出：
进程号：1；输出：4 进程号：1；输出：5 进程号：1；输出：6 进程号：1；输出：7 进程号：2；输出：8 进程号：2；输出：9 进程号：2；输出：10 进程号：2；输出：11 进程号：3；输出：12 进程号：3；输出：13 进程号：3；输出：14 进程号：3；输出：15 进程号：4；输出：16 进程号：4；输出：17 进程号：4；输出：18 进程号：0；输出：0 进程号：0；输出：1 进程号：0；输出：2 进程号：0；输出：3
感谢各位的阅读！关于“php如何使用多进程”这篇文章就分享到这里了，希望以上内容可以对大家有一定的帮助，让大家可以学到更多知识，如果觉得文章不错，可以把它分享出去让更多的人看到吧！
