SimpleFork php多进程并发框架

php中文网

发布时间：2016-07-30 13:29:40

1452人浏览过

来源于php中文网

原创

SimpleFork
项目地址：https://github.com/huyanping/simple-fork-php基于PCNTL扩展的多进程进程并发框架，接口类似与Java的Thread和Runnable为什么要写SimpleFork
多进程程序的编写相比较多线程编写更加复杂，需要考虑进程回收、同步、互斥、通信等问题。对于初学者来说，处理上述问题会比较困难。尤其是信号处理和进程通信这块，很难做到不出问题。 SimpleFork提供一套类似于JAVA多线程的进程控制接口，提供回收、同步、互斥、通信等方案，开发者可以关注业务问题，不需要过多考虑进程控制。引入

composer require jenner/simple_fork

<span><span>require</span><span>path</span><span>/</span><span>to</span><span>/</span><span>SimpleFork</span><span>/</span><span>autoload</span><span>.</span><span>php</span></span>

依赖
必须

ext-pcntl 进程控制

可选

ext-sysvmsg 消息队列

ext-sysvsem 同步互斥锁

ext-sysvshm 共享内存

特性

提供进程池

自动处理僵尸进程回收，支持无阻塞调用

提供共享内存、System V 消息队列、Semaphore锁，方便IPC通信（进程通信）

提供Process和Runnable两种方式实现进程

可以实时获取到进程状态

shutdown所有进程或单独stop一个进程时，可以注册覆盖beforeExit()方法，返回true则退出，false继续运行（在某些场景，进程不能立即退出）

支持子进程运行时reload

注意事项

System V 消息队列由于在程序退出时可能存在尚未处理完的数据，所以不会销毁。如果需要销毁，请调用$queue->remove()方法删除队列

共享内存会在所有进程退出后删除

Semaphore对象会在对象回收时进行销毁

进程池start()后，需要调用wait()进行僵尸进程回收，可以无阻塞调用

获取进程状态(调用isAlive()方法)前，最好调用一个无阻塞的wait(false)进行一次回收，由于进程运行状态的判断不是原子操作，所以isAlive()方法不保证与实际状态完全一致

如果你不清楚在什么情况下需要在程序的最开始加入declare(ticks=1);，那么最好默认第一行都加入这段声明。

如何使用declare(ticks=1);

declare(ticks=1); 这段声明用于进程信号处理。如果注册了信号处理器，程序会没执行一行代码后自动检查是否有尚未处理的信号。http://php.net/manual/zh/control-structures.declare.php

TODO

提供更多功能的进程池，模仿java

提供第三方进程通信机制（Redis等）

更多的测试及示例程序

示例程序
更多示例程序见exmples目录simple.php

<span><span>class</span><span>TestRunnable</span><span>extends</span><span>\Jenner\SimpleFork\</span><span>Runnable</span>{</span><span><span>/**</span></span><span><span>     * 进程执行入口</span></span><span><span>     * <span>@return</span> mixed</span></span><span><span>     */</span></span><span><span>public</span><span>function</span><span>run</span>()</span><span>    {</span><span><span>echo</span><span><span>"</span>I am a sub process<span>"</span></span><span>.</span><span>PHP_EOL</span>;</span><span>    }</span><span>}</span><span><span>$process</span><span>=</span><span>new</span><span>\Jenner\SimpleFork\</span><span>Process</span>(<span>new</span><span>TestRunnable</span>());</span><span><span>$process</span><span>-></span>start();</span>

shared_memory.php

<span><span>class</span><span>Producer</span><span>extends</span><span>\Jenner\SimpleFork\</span><span>Process</span>{</span><span><span>public</span><span>function</span><span>run</span>(){</span><span><span>for</span>(<span>$i</span><span>=</span><span>0</span>; <span>$i</span><span><</span><span>10</span>; <span>$i</span><span>&#43;&#43;</span>){</span><span><span>$this</span><span>-></span><span>cache</span><span>-></span>set(<span>$i</span>, <span>$i</span>);</span><span><span>echo</span><span><span>"</span>set {<span>$i</span>} : {<span>$i</span>}<span>"</span></span><span>.</span><span>PHH_EOL</span>;</span><span>        }</span><span>    }</span><span>}</span><span><span>class</span><span>Worker</span><span>extends</span><span>\Jenner\SimpleFork\</span><span>Process</span>{</span><span><span>public</span><span>function</span><span>run</span>(){</span><span><span>sleep</span>(<span>5</span>);</span><span><span>for</span>(<span>$i</span><span>=</span><span>0</span>; <span>$i</span><span><</span><span>10</span>; <span>$i</span><span>&#43;&#43;</span>){</span><span><span>echo</span><span><span>"</span>get {<span>$i</span>} : <span>"</span></span><span>.</span><span>$this</span><span>-></span><span>cache</span><span>-></span>get(<span>$i</span>) <span>.</span><span>PHP_EOL</span>;</span><span>        }</span><span>    }</span><span>}</span><span><span>$memory</span><span>=</span><span>new</span><span>\Jenner\SimpleFork\IPC\</span><span>SharedMemory</span>();</span><span><span>$producer</span><span>=</span><span>new</span><span>Producer</span>();</span><span><span>$producer</span><span>-></span>setCache(<span>$memory</span>);</span><span><span>$worker</span><span>=</span><span>new</span><span>Worker</span>();</span><span><span>$worker</span><span>-></span>setCache(<span>$memory</span>);</span><span><span>$pool</span><span>=</span><span>new</span><span>\Jenner\SimpleFork\</span><span>Pool</span>();</span><span><span>$pool</span><span>-></span>submit(<span>$producer</span>);</span><span><span>$pool</span><span>-></span>submit(<span>$worker</span>);</span><span><span>$pool</span><span>-></span>start();</span><span><span>$pool</span><span>-></span>wait();</span>

原创文章，转载请注明：转载自始终不够

Napkin AI

Napkin AI 可以将您的文本转换为图表、流程图、信息图、思维导图视觉效果，以便快速有效地分享您的想法。

下载

本文链接地址: SimpleFork php多进程并发框架

转载请注明：始终不够 ? SimpleFork php多进程并发框架

以上就介绍了SimpleFork php多进程并发框架，包括了方面的内容，希望对PHP教程有兴趣的朋友有所帮助。

php中nbsp是什么意思

如何从PHP中调用Python文件？

我们如何使用使用mysql_fetch_assoc()函数的PHP脚本来显示MySQL表中的所有记录？

ini_set()在PHP中的作用是什么？

在PHP中的readlink()函数

PHP速学教程(入门到精通)

PHP怎么学习？PHP怎么入门？PHP在哪学？PHP怎么学才快？不用担心，这里为大家提供了PHP速学教程(入门到精通)，有需要的小伙伴保存下载就能学习啦！

下载

相关专题

TypeScript类型系统进阶与大型前端项目实践

本专题围绕 TypeScript 在大型前端项目中的应用展开，深入讲解类型系统设计与工程化开发方法。内容包括泛型与高级类型、类型推断机制、声明文件编写、模块化结构设计以及代码规范管理。通过真实项目案例分析，帮助开发者构建类型安全、结构清晰、易维护的前端工程体系，提高团队协作效率与代码质量。

2026.03.13

Python异步编程与Asyncio高并发应用实践

本专题围绕 Python 异步编程模型展开，深入讲解 Asyncio 框架的核心原理与应用实践。内容包括事件循环机制、协程任务调度、异步 IO 处理以及并发任务管理策略。通过构建高并发网络请求与异步数据处理案例，帮助开发者掌握 Python 在高并发场景中的高效开发方法，并提升系统资源利用率与整体运行性能。

2026.03.12

C# ASP.NET Core微服务架构与API网关实践

本专题围绕 C# 在现代后端架构中的微服务实践展开，系统讲解基于 ASP.NET Core 构建可扩展服务体系的核心方法。内容涵盖服务拆分策略、RESTful API 设计、服务间通信、API 网关统一入口管理以及服务治理机制。通过真实项目案例，帮助开发者掌握构建高可用微服务系统的关键技术，提高系统的可扩展性与维护效率。

178

2026.03.11

Go高并发任务调度与Goroutine池化实践

本专题围绕 Go 语言在高并发任务处理场景中的实践展开，系统讲解 Goroutine 调度模型、Channel 通信机制以及并发控制策略。内容包括任务队列设计、Goroutine 池化管理、资源限制控制以及并发任务的性能优化方法。通过实际案例演示，帮助开发者构建稳定高效的 Go 并发任务处理系统，提高系统在高负载环境下的处理能力与稳定性。

2026.03.10

Kotlin Android模块化架构与组件化开发实践

本专题围绕 Kotlin 在 Android 应用开发中的架构实践展开，重点讲解模块化设计与组件化开发的实现思路。内容包括项目模块拆分策略、公共组件封装、依赖管理优化、路由通信机制以及大型项目的工程化管理方法。通过真实项目案例分析，帮助开发者构建结构清晰、易扩展且维护成本低的 Android 应用架构体系，提升团队协作效率与项目迭代速度。

2026.03.09

JavaScript浏览器渲染机制与前端性能优化实践

本专题围绕 JavaScript 在浏览器中的执行与渲染机制展开，系统讲解 DOM 构建、CSSOM 解析、重排与重绘原理，以及关键渲染路径优化方法。内容涵盖事件循环机制、异步任务调度、资源加载优化、代码拆分与懒加载等性能优化策略。通过真实前端项目案例，帮助开发者理解浏览器底层工作原理，并掌握提升网页加载速度与交互体验的实用技巧。

102

2026.03.06

Rust内存安全机制与所有权模型深度实践

本专题围绕 Rust 语言核心特性展开，深入讲解所有权机制、借用规则、生命周期管理以及智能指针等关键概念。通过系统级开发案例，分析内存安全保障原理与零成本抽象优势，并结合并发场景讲解 Send 与 Sync 特性实现机制。帮助开发者真正理解 Rust 的设计哲学，掌握在高性能与安全性并重场景中的工程实践能力。

227

2026.03.05

PHP高性能API设计与Laravel服务架构实践

本专题围绕 PHP 在现代 Web 后端开发中的高性能实践展开，重点讲解基于 Laravel 框架构建可扩展 API 服务的核心方法。内容涵盖路由与中间件机制、服务容器与依赖注入、接口版本管理、缓存策略设计以及队列异步处理方案。同时结合高并发场景，深入分析性能瓶颈定位与优化思路，帮助开发者构建稳定、高效、易维护的 PHP 后端服务体系。

532

2026.03.04