>  기사  >  백엔드 개발  >  SimpleFork php多进程并发框架

SimpleFork php多进程并发框架

WBOY
WBOY원래의
2016-07-30 13:29:401177검색
SimpleFork
项目地址:https://github.com/huyanping/simple-fork-php基于PCNTL扩展的多进程进程并发框架,接口类似与Java的Thread和Runnable为什么要写SimpleFork
多进程程序的编写相比较多线程编写更加复杂,需要考虑进程回收、同步、互斥、通信等问题。对于初学者来说,处理上述问题会比较困难。 尤其是信号处理和进程通信这块,很难做到不出问题。 SimpleFork提供一套类似于JAVA多线程的进程控制接口,提供回收、同步、互斥、通信等方案,开发者可以关注业务问题,不需要过多考虑进程控制。引入
composer require jenner/simple_forkrequirepath/to/SimpleFork/autoload.php依赖
必须
  •  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.phpclassTestRunnableextends\Jenner\SimpleFork\Runnable{/** * 进程执行入口 * @return mixed */publicfunctionrun() {echo"I am a sub process".PHP_EOL; }}$process=new\Jenner\SimpleFork\Process(newTestRunnable());$process->start();shared_memory.phpclassProducerextends\Jenner\SimpleFork\Process{publicfunctionrun(){for($i=0; $i10; $i++){$this->cache->set($i, $i);echo"set {$i} : {$i}".PHH_EOL; } }}classWorkerextends\Jenner\SimpleFork\Process{publicfunctionrun(){sleep(5);for($i=0; $i10; $i++){echo"get {$i} : ".$this->cache->get($i) .PHP_EOL; } }}$memory=new\Jenner\SimpleFork\IPC\SharedMemory();$producer=newProducer();$producer->setCache($memory);$worker=newWorker();$worker->setCache($memory);$pool=new\Jenner\SimpleFork\Pool();$pool->submit($producer);$pool->submit($worker);$pool->start();$pool->wait();

    原创文章,转载请注明: 转载自始终不够

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

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

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

    성명:
    본 글의 내용은 네티즌들의 자발적인 기여로 작성되었으며, 저작권은 원저작자에게 있습니다. 본 사이트는 이에 상응하는 법적 책임을 지지 않습니다. 표절이나 침해가 의심되는 콘텐츠를 발견한 경우 admin@php.cn으로 문의하세요.
    이전 기사:Laravel 安装记录다음 기사:33 PHP Sessions