php 的多进程
php的多进程处理依赖于pcntl扩展，通过pcntl_fork创建子进程来进行并行处理
例子1：
<?php
$pid = pcntl_fork(); if($pid == -1) {
//错误处理：创建子进程失败时返回-1.
die('fork error');
} else if ($pid) {
//父进程会得到子进程号，所以这里是父进程执行的逻辑
echo "parent \n";
//等待子进程中断，防止子进程成为僵尸进程。
pcntl_wait($status);
} else {
//子进程得到的$pid为0, 所以这里是子进程执行的逻辑。
echo "child \n"; exit;
}
pcntl_fork创建了子进程，父进程和子进程都继续向下执行，而不同是父进程会获取子进程的$pid也就是$pid不为零。而子进程会获取$pid为零。通过if else语句判断$pid我们就可以在指定位置写上不同的逻辑代码。
上述代码会分别输出parent和child。那么输出的parent和child是否会有顺序之分？是父进程会先执行？
例子2：
<?php
$pid = pcntl_fork(); if($pid == -1) {
die('fork error');
} else if ($pid) {
sleep(3);
echo "parent \n";
pcntl_wait($status);
} else {
echo "child \n"; exit;
}
很快输出了child，等待了接近3秒后，才输出parent。所以父进程和子进程的执行是相对独立的，没有先后之分。
那么问题又来了？pcntl_wait是做什么用的？
会挂起当前进程，直到子进程退出，如果子进程在调用此函数之前就已退出，此函数会立刻返回。子进程使用的资源将被释放。
例子3：
<?php
$pid = pcntl_fork(); if($pid == -1) {
die('fork error');
} else if ($pid) {
pcntl_wait ($status);
echo "parent \n";
} else {
sleep(3);
echo "child \n"; exit;
}
我们可以看到，父进程执行pcntl_wait时就已经挂起，直到等待3秒后输出child，子进程退出后。父进程继续执行，输出parent。
例子4：
<?php
define('FORK_NUMS', 3); $pids = array(); for($i = 0; $i < FORK_NUMS; ++$i) {
$pids[$i] = pcntl_fork();
if($pids[$i] == -1) {
die('fork error');
} else if ($pids[$i]) {
pcntl_waitpid($pids[$i], $status);
echo "pernet \n";
} else {
sleep(3);
echo "child id:" . getmypid() . " \n";
exit;
}
}
我们创建3个子进程，父进程分别挂起等待子进程结束后，输出parent。
输出结果如下：
例子5：
<?php
define('FORK_NUMS', 3); $pids = array(); for($i = 0; $i < FORK_NUMS; ++$i) {
$pids[$i] = pcntl_fork();
if($pids[$i] == -1) {
die('fork error');
} else if ($pids[$i]) { } else {
sleep(3);
echo "child id:" . getmypid() . " \n";
exit;
}
} foreach($pids as $k => $v) {
if($v) {
pcntl_waitpid($v, $status);
echo "parent \n";
}
}
输出结果：
为什么上述代码跟例4的输出结果不一样？
我们可以看到例5的pcntl_waitpid函数放在了foreach中，foreach代码是在主进程中，也就是父进程的代码中。当执行foreach时，可能子进程已经全部执行完毕并退出。pcntl_waitpid会立刻返回，连续输出三个parent。
(*在子进程中，需通过exit来退出，不然会产生递归多进程，父进程中不需要exit，不然会中断多进程。)
例子6：
<?php
define('FORK_NUMS', 3);
$pids = array();
$fp = fopen('./test.log', 'wb');
$num = 1;
for($i = 0; $i < FORK_NUMS; ++$i) {
$pids[$i] = pcntl_fork();
if($pids[$i] == -1) {
die('fork error');
} else if ($pids[$i]) {
} else {
for($i = 0; $i < 5; ++$i) {
flock($fp, LOCK_EX);
fwrite($fp, getmypid() . ' : ' . date('Y-m-d H:i:s') . " : {$num} \r\n");
flock($fp, LOCK_UN);
echo getmypid(), ": success \r\n";
++$num;
}
exit;
}
}
foreach($pids as $k => $v) {
if($v) {
pcntl_waitpid($v, $status);
}
}
fclose($fp);
可以看到三个子进程的pid，它们分别执行了5次，时间几乎是在同时。但是$num的值并没像我们期望的那样从1－15进行递增。子进程中的变量是各自独立的，互不影响。子进程会自动复制父进程空间里的变量。
如何在进程中共享数据？
我们通过php的共享内存函数shmop来实现。
例子7:
<?php
define('FORK_NUMS', 3);
$pids = array();
$fp = fopen('./test.log', 'wb');
$num = 1;
//共享内存段的key
$shmKey = 123;
//创建共享内存段
$shmId = shmop_open($shmKey, 'c', 0777, 64);
//写入数据到共享内存段
shmop_write($shmId, $num, 0);
for($i = 0; $i < FORK_NUMS; ++$i) {
$pids[$i] = pcntl_fork();
if($pids[$i] == -1) {
die('fork error');
} else if ($pids[$i]) {
//阻塞，等待子进程退出
//注意这里，如果是非阻塞的话，$num的计数会出现问题。
pcntl_waitpid($pids[$i], $status);
} else {
//读取共享内存段中的数据
$num = shmop_read($shmId, 0, 64);
for($i = 0; $i < 5; ++$i) {
fwrite($fp, getmypid() . ' : ' . date('Y-m-d H:i:s') . " : {$num} \r\n");
echo getmypid(), ": success \r\n";
//递增$num
$num = intval($num) + 1;
}
//写入到共享内存段中
shmop_write($shmId, $num, 0);
exit;
}
}
//shmop_delete不会实际删除该内存段，它将该内存段标记为删除。
shmop_delete($shmId);
shmop_close($shmId);
fclose($fp);
最后结果：
这样我们就在进程间共享了$num的数据
最新文章
- mysql-5.6.34 Installation from Source code
- Centos6下安装高版本Git
- 编译PCL Tutorial文件
- hangfire+bootstrap ace 模板实现后台任务管理平台
- 豆瓣的账号登录及api操作
- Linux下的PostgreSQL简单安装手册
- Python学习笔记总结1：字符串表示str与repr的用法比较
- 【WCF】Silverlight+wcf+自定义用户名密码验证
- mac 查看系统时区
- 微信小程序登录数据解密以及状态维持
- 《java.util.concurrent 包源码阅读》13 线程池系列之ThreadPoolExecutor 第三部分
- Python的序列类型——List
- bzoj4568(合并线性基+倍增)
- 小程序wxRequest封装
- Linux今日疑问
- CentOS7 虚拟机设置文件共享 VMWareTools安装遇到的坑
- 关于mysql_connect CLIENT_MULTI_RESULTS
- notepad++ 行首行尾添加字符
- WebService之XFire和SOAP实例(基于JAVA)
- dm8148 开发之---sii9022a hdmi传输器