文件名称：php多进程框架-模拟java多线程接口simple-fork-php.zip
文件大小：49KB
文件格式：ZIP
更新时间：2022-08-08 00:41:21
开源项目
SimpleFork simple-fork-php 是基于 PCNTL 扩展的进程管理包，接口类似与 Java 的 Thread 和 Runnable 为什么要写 SimpleFork 多进程程序的编写相比较多线程编写更加复杂，需要考虑进程回收、同步、互斥、通信等问题。对于初学者来说，处理上述问题会比较困难。 尤其是信号处理和进程通信这块，很难做到不出问题。 SimpleFork提供一套类似于JAVA多线程的进程控制接口，提供回收、同步、互斥、通信等方案，开发者可以关注业务问题，不需要过多考虑进程控制。 引入 composer require jenner/simple_fork require path/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.php class TestRunnable extends \Jenner\SimpleFork\Runnable{ /** * 进程执行入口 * @return mixed */ public function run() { echo "I am a sub process" . PHP_EOL; } } $process = new \Jenner\SimpleFork\Process(new TestRunnable()); $process->start(); shared_memory.php class Producer extends \Jenner\SimpleFork\Process{ public function run(){ for($i = 0; $i<10; $i ){ $this->cache->set($i, $i); echo "set {$i} : {$i}" . PHH_EOL; } } } class Worker extends \Jenner\SimpleFork\Process{ public function run(){ sleep(5); for($i=0; $i<10; $i ){ echo "get {$i} : " . $this->cache->get($i) . PHP_EOL; } } } $memory = new \Jenner\SimpleFork\IPC\SharedMemory(); $producer = new Producer(); $producer->setCache($memory); $worker = new Worker(); $worker->setCache($memory); $pool = new \Jenner\SimpleFork\Pool(); $pool->submit($producer); $pool->submit($worker); $pool->start(); $pool->wait(); 标签：simple
【文件预览】：
simple-fork-php-master
----.scrutinizer.yml(613B)
----README.ZH.MD(4KB)
----src()
--------Pool.php(627B)
--------Runnable.php(234B)
--------Queue()
--------PoolFactory.php(1001B)
--------Utils.php(1KB)
--------ParallelPool.php(3KB)
--------Process.php(8KB)
--------Cache()
--------AbstractPool.php(4KB)
--------Lock()
--------SinglePool.php(452B)
--------FixedPool.php(1KB)
----examples()
--------shared_memory.php(920B)
--------message_queue.php(977B)
--------semaphore.php(930B)
--------single_pool.php(739B)
--------pool.php(659B)
--------pipe.php(556B)
--------redis-queue()
--------callback.php(400B)
--------parallel_pool.php(561B)
--------shutdown.php(566B)
--------simple.php(480B)
--------fixed_pool.php(740B)
--------pipe_queue.php(380B)
--------queue()
--------pool_nowait.php(775B)
----.travis.yml(442B)
----LICENSE(1KB)
----phpunit.xml(182B)
----README.md(9KB)
----autoload.php(488B)
----tests()
--------SharedMemoryTest.php(1KB)
--------ProcessTest.php(3KB)
--------shared_memory.php(345B)
--------semaphore.php(616B)
--------FixedPoolTest.php(1KB)
--------PipeTest.php(2KB)
--------RedisCacheTest.php(771B)
--------FileCacheTest.php(1KB)
--------RedisQueueTest.php(1KB)
--------PipeQueueTest.php(423B)
--------autoload_test.php(237B)
--------FileLockTest.php(2KB)
--------SemaphoreTest.php(2KB)
--------shared_memory_bug.php(530B)
--------filelock.php(850B)
--------PoolTest.php(2KB)
--------ParallelPoolTest.php(1KB)
--------UtilsTest.php(684B)
--------fast.php(437B)
--------SystemVMessageQueueTest.php(918B)
----.gitignore(28B)
----composer.json(485B)