Process Pool

Manage a pool of Linux worker processes with Swoole. It can be used to manage a group of worker processes to process messages in MQ like Redis or sent from client side. Native Linux commands can also be executed by the pool of processes.

When a process in the pool is terminated, the pool starts a replacement process automatically.

Methods

• OpenSwoole\Process\Pool::__construct
• OpenSwoole\Process\Pool->set
• OpenSwoole\Process\Pool->on
• OpenSwoole\Process\Pool->getProcess
• OpenSwoole\Process\Pool->listen
• OpenSwoole\Process\Pool->start
• OpenSwoole\Process\Pool->shutdown
• OpenSwoole\Process\Pool->write
• OpenSwoole\Process\Pool->detach

Events

• OpenSwoole\Process\Pool->on('start', fn)
• OpenSwoole\Process\Pool->on('stop', fn)
• OpenSwoole\Process\Pool->on('workerstart', fn)
• OpenSwoole\Process\Pool->on('workerstop', fn)
• OpenSwoole\Process\Pool->on('message', fn)

Example

<?php

$workerNum = 10;
$pool = new OpenSwoole\Process\Pool($workerNum);

$pool->on("WorkerStart", function ($pool, $workerId) {
    echo "Worker#{$workerId} is started\n";
    $redis = new Redis();
    $redis->pconnect('127.0.0.1', 6379);
    $key = "key1";
    while (true) {
         $msgs = $redis->brpop($key, 2);
         if ( $msgs == null) continue;
         var_dump($msgs);
     }
});

$pool->on("WorkerStop", function ($pool, $workerId) {
    echo "Worker#{$workerId} is stopped\n";
});

$pool->start();