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>++</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>++</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>登录后复制
原创文章，转载请注明： 转载自始终不够
本文链接地址: SimpleFork
php多进程并发框架
转载请注明：始终不够 ? SimpleFork
php多进程并发框架
以上就介绍了SimpleFork php多进程并发框架，包括了方面的内容，希望对PHP教程有兴趣的朋友有所帮助。
本文内容由网友自发贡献，版权归原作者所有，本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容，请联系admin@php.cn
总结
广告![ThinkPHP5快速开发企业站点[全程实录]](https://img.php.cn/upload/course/000/000/068/6253d918a3ce7278.png)
收藏
下载豆包电脑版，提高工作效率
524
