• 150648

    文章

  • 1251

    评论

  • 10

    友链

  • 最近新加了换肤功能,大家多来逛逛吧~~~~
  • 喜欢这个网站的朋友可以加一下QQ群,我们一起交流技术。

PCF- PHP 并发框架

撸了今年阿里、腾讯和美团的面试,我有一个重要发现.......>>

php并发框架,让开发的脚本自动并发运行起来

PCF主要有两个目的:
1.使并发程序写起来更容易。写的单个脚本可以自动并发跑起来
2.使并发控制更简单。并发的进程数可以随时增多和减少,特意暂停或意外中止的程序会记录暂停点,
  下次执行时从暂停点继续执行。

PCF的框架图如下

假设我们有如下的数据处理需求: 一共有200个表的数据,每个表有一百万的数据,对于每个数据要进行某种处理。

为了高效处理,需要进行并发处理,用户代码示例如下,假如在文件usercode.php中:

<?php  

require_once 'currFrame.php';//包含框架代码

define('TABLENUM',10);

//用户类继承框架类
class Example extends CurrFrame { 
	/**
	 * 产生消息
	 */
	public function produce(){
	
		for ($i = 0;$i <TABLENUM ;$i++){
			$this->addMsg($i);//添加消息,此处为表序号
		}
		$this->endMsg(); //结束消息,如果没有更多消息,就要结束,否则总会尝试读取更多消息
	}

	/**
	 * 具体处理代码
	 * @param  $msg 当前处理的消息
	 * @param  $pos  当前处理到的位置  
	 */
	public function process($msg,$pos = NULL) {
		
		$no = $msg;
	    $j = $pos ==NULL ? 0:$pos;
	   
		for(;$j<10;$j++){
		    //此处放具体处理逻辑
		    
			$this->recordProcess($j); //记录处理进度
		}
	}
	
	/**
	 *所有进程运行完成后执行的代码
	 */
	public function output(){
		
	}
}

$obj = new Example();
$obj->run();

启动并发只要执行 php usercode.php batch 3 ,表示启动3个并发,可以随时更改并发的参数,也可以设为0,表示停止所有的处理

 


软件首页 软件文档 官方下载 极速下载



自定义皮肤 主体内容背景
打开支付宝扫码付款购买视频教程
遇到问题联系客服QQ:419400980
注册梁钟霖个人博客