有人做家具网站中介吗,南宁如何做百度的网站推广,百度搜索网站排名,沈阳做网站的互联网公司一、引言 进程是一个具有独立功能的程序关于某个数据集合的一次运行活动。换句话说就是#xff0c;在系统调度多个cpu的时候#xff0c;一个程序的基本单元。进程对于大多数的语言都不是一个陌生的概念#xff0c;作为世界上最好的语言PHP当然也例外。 二、环境…一、引言 进程是一个具有独立功能的程序关于某个数据集合的一次运行活动。换句话说就是在系统调度多个cpu的时候一个程序的基本单元。进程对于大多数的语言都不是一个陌生的概念作为世界上最好的语言PHP当然也例外。 二、环境 php中的进程是以扩展的形式来完成。通过这些扩展我们能够很轻松的完成进程的一系列动作。 pcntl扩展主要的进程扩展完成进程创建于等待操作。posix扩展完成posix兼容机通用api,如获取进程id,杀死进程等。sysvmsg扩展实现system v方式的进程间通信之消息队列。sysvsem扩展实现system v方式的信号量。sysvshm扩展实现system v方式的共享内存。sockets扩展实现socket通信。这些扩展只能在linux/mac中使用window下是不支持。最后建议php版本为5.5。 三、简单的例子 一个简单的PHP多进程例子该例子中一个子进程一个父进程。子进程输出5次退出程序。 $parentPid posix_getpid();
echo parent progress pid:{$parentPid}\n;
$childList array();
$pid pcntl_fork();
if ( $pid -1) {// 创建失败exit(fork progress error!\n);
} else if ($pid 0) {// 子进程执行程序$pid posix_getpid();$repeatNum 5;for ( $i 1; $i $repeatNum; $i) {echo ({$pid})child progress is running! {$i} \n;$rand rand(1,3);sleep($rand);}exit(({$pid})child progress end!\n);
} else {// 父进程执行程序$childList[$pid] 1;
}
// 等待子进程结束
pcntl_wait($status);
echo ({$parentPid})main progress end!; 完美终于创建了一个子进程一个父进程。完了么没有各个进程之间相互独立的没有任何交集使用范围严重受到现在。怎么办哪就进程间通信(interprogress communication)呗。 四、进程间通信IPC 通常linux中的进程通信方式有消息队列、信号量、共享内存、信号、管道、socket。 1.消息队列 消息队列是存放在内存中的一个队列。如下代码将创建3个生产者子进程2个消费者子进程。这5个进程将通过消息队列通信。 $parentPid posix_getpid();
echo parent progress pid:{$parentPid}\n;$childList array();
// 创建消息队列,以及定义消息类型(类似于数据库中的库)
$id ftok(__FILE__,m);
$msgQueue msg_get_queue($id);
const MSG_TYPE 1;
// 生产者
function producer(){global $msgQueue;$pid posix_getpid();$repeatNum 5;for ( $i 1; $i $repeatNum; $i) {$str ({$pid})progress create! {$i};msg_send($msgQueue,MSG_TYPE,$str);$rand rand(1,3);sleep($rand);}
}
// 消费者
function consumer(){global $msgQueue;$pid posix_getpid();$repeatNum 6;for ( $i 1; $i $repeatNum; $i) {$rel msg_receive($msgQueue,MSG_TYPE,$msgType,1024,$message);echo {$message} | consumer({$pid}) destroy \n;$rand rand(1,3);sleep($rand);}
}
function createProgress($callback){$pid pcntl_fork();if ( $pid -1) {// 创建失败exit(fork progress error!\n);} else if ($pid 0) {// 子进程执行程序$pid posix_getpid();$callback();exit(({$pid})child progress end!\n);}else{// 父进程执行程序return $pid;}
}
// 3个写进程
for ($i 0; $i 3; $i ) {$pid createProgress(producer);$childList[$pid] 1;echo create producer child progress: {$pid} \n;
}
// 2个写进程
for ($i 0; $i 2; $i ) {$pid createProgress(consumer);$childList[$pid] 1;echo create consumer child progress: {$pid} \n;
}
// 等待所有子进程结束
while(!empty($childList)){$childPid pcntl_wait($status);if ($childPid 0){unset($childList[$childPid]);}
}
echo ({$parentPid})main progress end!\n; 由于消息队列去数据是只有一个进程能去到所以不需要额外的锁或信号量。 2. 信号量与共享内存 信号量是系统提供的一种原子操作一个信号量同时只有你个进程能操作。一个进程获得了某个信号量就必须被该进程释放掉。 共享内存是系统在内存中开辟的一块公共的内存区域任何一个进程都可以访问在同一时刻可以有多个进程访问该区域为了保证数据的一致性需要对该内存区域加锁或信号量。 以下创建多个进程修改内存中的同一个值。 $parentPid posix_getpid();
echo parent progress pid:{$parentPid}\n;
$childList array();// 创建共享内存,创建信号量,定义共享key
$shm_id ftok(__FILE__,m);
$sem_id ftok(__FILE__,s);
$shareMemory shm_attach($shm_id);
$signal sem_get($sem_id);
const SHARE_KEY 1;
// 生产者
function producer(){global $shareMemory;global $signal;$pid posix_getpid();$repeatNum 5;for ( $i 1; $i $repeatNum; $i) {// 获得信号量sem_acquire($signal);if (shm_has_var($shareMemory,SHARE_KEY)){// 有值,加一$count shm_get_var($shareMemory,SHARE_KEY);$count ;shm_put_var($shareMemory,SHARE_KEY,$count);echo ({$pid}) count: {$count}\n;}else{// 无值,初始化shm_put_var($shareMemory,SHARE_KEY,0);echo ({$pid}) count: 0\n;}// 用完释放sem_release($signal);$rand rand(1,3);sleep($rand);}
}
function createProgress($callback){$pid pcntl_fork();if ( $pid -1) {// 创建失败exit(fork progress error!\n);} else if ($pid 0) {// 子进程执行程序$pid posix_getpid();$callback();exit(({$pid})child progress end!\n);}else{// 父进程执行程序return $pid;}
}
// 3个写进程
for ($i 0; $i 3; $i ) {$pid createProgress(producer);$childList[$pid] 1;echo create producer child progress: {$pid} \n;
}
// 等待所有子进程结束
while(!empty($childList)){$childPid pcntl_wait($status);if ($childPid 0){unset($childList[$childPid]);}
}
// 释放共享内存与信号量
shm_remove($shareMemory);
sem_remove($signal);
echo ({$parentPid})main progress end!\n; 3.信号 信号是一种系统调用。通常我们用的kill命令就是发送某个信号给某个进程的。具体有哪些信号可以在liunx/mac中运行kill -l查看。下面这个例子中父进程等待5秒钟向子进程发送sigint信号。子进程捕获信号掉信号处理函数处理。 $parentPid posix_getpid();
echo parent progress pid:{$parentPid}\n;// 定义一个信号处理函数
function sighandler($signo) {$pid posix_getpid();echo {$pid} progress,oh no ,Im killed!\n;exit(1);
}$pid pcntl_fork();
if ( $pid -1) {// 创建失败exit(fork progress error!\n);
} else if ($pid 0) {// 子进程执行程序// 注册信号处理函数declare(ticks10);pcntl_signal(SIGINT, sighandler);$pid posix_getpid();while(true){echo {$pid} child progress is running!\n;sleep(1);}exit(({$pid})child progress end!\n);
}else{// 父进程执行程序$childList[$pid] 1;// 5秒后,父进程向子进程发送sigint信号.sleep(5);posix_kill($pid,SIGINT);sleep(5);
}
echo ({$parentPid})main progress end!\n; 4.管道有名管道 管道是比较常用的多进程通信手段管道分为无名管道与有名管道无名管道只能用于具有亲缘关系的进程间通信而有名管道可以用于同一主机上任意进程。这里只介绍有名管道。下面的例子子进程写入数据父进程读取数据。 // 定义管道路径,与创建管道
$pipe_path /data/test.pipe;
if(!file_exists($pipe_path)){if(!posix_mkfifo($pipe_path,0664)){exit(create pipe error!);}
}
$pid pcntl_fork();
if($pid 0){// 子进程,向管道写数据$file fopen($pipe_path,w);while (true){fwrite($file,hello world);$rand rand(1,3);sleep($rand);}exit(child end!);
}else{// 父进程,从管道读数据$file fopen($pipe_path,r);while (true){$rel fread($file,20);echo {$rel}\n;$rand rand(1,2);sleep($rand);}
} 5.socket socket即我们常说的套接字编程。这个待补充。转载于:https://www.cnblogs.com/aksir/p/6777671.html
