PCF

PHP 并发框架
授权协议 GPL
开发语言 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,表示停止所有的处理

 
 相关资料
  • 主要内容:1.Disruptor介绍,2.Disruptor 的核心概念,3.demo1.Disruptor介绍 Disruptor是一个开源的Java框架,它被设计用于在生产者—消费者(producer-consumer problem,简称PCP)问题上获得尽量高的吞吐量(TPS)和尽量低的延迟。 从功能上来看,Disruptor 是实现了“队列”的功能,而且是一个有界队列。那么它的应用场景自然就是“生产者-消费者”模型的应用场合了。 其实Disruptor与其说是一个框架,不

  • 主要内容:Fork,Join,ForkJoinPool,RecursiveAction,递归任务,实例框架允许在几个工作进程中断某个任务,然后等待结果组合它们。 它在很大程度上利用了多处理器机器的生产能力。 以下是框架中使用的核心概念和对象。 Fork Fork是一个进程,其中任务将其分成可以并发执行的较小且独立的子任务。 语法 这里是的子类,方法将任务分解为子任务。 Join 连接()是子任务完成执行后任务加入子任务的所有结果的过程,否则它会持续等待。 语法 这里剩下的是类的一个对象。 For

  • 前述关于线程的栈大小问题,其实栈是可以动态增长的,只不过为了效率问题,一般都是固定的,这是一个实现相关,并非线程的原罪;不过说的第二点,线程调度需要陷入内核,这个的确非常影响效率。而协程没有这两个问题,首先所有协程本质是可以在一个线程里面执行,一个协程切换的时候是暂时返回,执行栈都是复用的,随便开个比较大的空间就行了,协程的状态在堆上申请,可以按需申请,因此协程可以开很多很多,百万级都没问题;另一

  • 问题内容: 我有以下代码: checkbox.php文件: 问题是我没有从$ _POST [‘foton’]中获得任何价值,这是怎么回事? 谢谢 问题答案: 在以下位置编辑代码: 在这里,你有一个参数,这就是所谓的和 值 是。 在我的代码中,您正在通过名为的 参数 发送复选框的值。 指定数据时,您无需在url中设置查询字符串(而不是您 想要 重定向到将部分处理参数的页面)。

  • 考虑以下方法: 尤其是这两条线: 如果线程A进入synchronized块并获得当前对象的锁,这是否意味着该对象的实例属性的状态不能被synchronized块之外的其他线程改变(当线程A在synchronized块中时)? 例如,线程A执行了第1行- 消息是非静态同步列表 UPD:更新的方法,可能的解决方案: addLock - AtomicBoolean,默认为false

  • 我需要一个线程安全的并发列表,同时最适合迭代,并且应该返回精确的大小。我想存储物品的拍卖出价。所以我想能够 检索项目的确切出价数量 为项目添加出价 检索给定项目的所有出价。 移除商品出价 我打算把它放在

  • 本文向大家介绍Java并发之线程池Executor框架的深入理解,包括了Java并发之线程池Executor框架的深入理解的使用技巧和注意事项,需要的朋友参考一下 线程池 无限制的创建线程 若采用"为每个任务分配一个线程"的方式会存在一些缺陷,尤其是当需要创建大量线程时: 线程生命周期的开销非常高 资源消耗 稳定性 引入线程池 任务是一组逻辑工作单元,线程则是使任务异步执行的机制。当存在大量并发任

  • "One does not live by bread alone,but by every word that comes from the mouth of God" --(MATTHEW4:4) python开发框架 不管是python,还是php,亦或别的做web项目的语言,乃至于做其它非web项目的开发,一般都要用到一个称之为什么什么框架的东西。 框架的基本概念 开发这对框架的认识,由于