PHP多线程编程之管道通信实例分析
本文实例讲述了PHP多线程编程之管道通信用法。分享给大家供大家参考。具体分析如下:
一个线程如果是个人英雄主义,那么多线程就是集体主义,你不再是一个独行侠,而是一个指挥家。
管道通信:
1.管道可以认为是一个队列,不同的线程都可以往里面写东西,也都可以从里面读东西。写就是
在队列末尾添加,读就是在队头删除。
2.管道一般有大小,默认一般是4K,也就是内容超过4K了,你就只能读,不能往里面写了。
3.默认情况下,管道写入以后,就会被阻止,直到读取他的程序读取把数据读完。而读取线程也会被阻止,
直到有进程向管道写入数据。当然,你可以改变这样的默认属性,用stream_set_block 函数,设置成非阻断模式。
下面是我分装的一个管道的类(这个类命名有问题,没有统一,没有时间改成统一的了,我一般先写测试代码,最后分装,所以命名上可能不统一):
<?php classPipe { public$fifoPath; private$w_pipe; private$r_pipe; /** *自动创建一个管道 * *@paramstring$name管道名字 *@paramint$mode管道的权限,默认任何用户组可以读写 */ function__construct($name='pipe',$mode=0666) { $fifoPath="/tmp/$name.".posix_getpid(); if(!file_exists($fifoPath)){ if(!posix_mkfifo($fifoPath,$mode)){ error("createnewpipe($name)error."); returnfalse; } }else{ error("pipe($name)hasexit."); returnfalse; } $this->fifoPath=$fifoPath; } /////////////////////////////////////////////////// //写管道函数开始 /////////////////////////////////////////////////// functionopen_write() { $this->w_pipe=fopen($this->fifoPath,'w'); if($this->w_pipe==NULL){ error("openpipe{$this->fifoPath}forwriteerror."); returnfalse; } returntrue; } functionwrite($data) { returnfwrite($this->w_pipe,$data); } functionwrite_all($data) { $w_pipe=fopen($this->fifoPath,'w'); fwrite($w_pipe,$data); fclose($w_pipe); } functionclose_write() { returnfclose($this->w_pipe); } ///////////////////////////////////////////////////////// ///读管道相关函数开始 //////////////////////////////////////////////////////// functionopen_read() { $this->r_pipe=fopen($this->fifoPath,'r'); if($this->r_pipe==NULL){ error("openpipe{$this->fifoPath}forreaderror."); returnfalse; } returntrue; } functionread($byte=1024) { returnfread($this->r_pipe,$byte); } functionread_all() { $r_pipe=fopen($this->fifoPath,'r'); $data=''; while(!feof($r_pipe)){ //echo"readoneK\n"; $data.=fread($r_pipe,1024); } fclose($r_pipe); return$data; } functionclose_read() { returnfclose($this->r_pipe); } /** *删除管道 * *@returnbooleanissuccess */ functionrm_pipe() { returnunlink($this->fifoPath); } } ?> /* 有了这个类,就可以实现简单的管道通信了。*/
希望本文所述对大家的php程序设计有所帮助。