Swoole\Process\Pool->on

Declaration

<?php
Swoole\Process\Pool->on(string $event, callback $callback)

Parameters

event

The event name

callback

callback function

Return

success

if success, it returns TRUE, otherwise it returns FALSE.

Description

Register callback function for the event.

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

    Example

    <?php
    
    $workerNum = 10;
    $pool = new Swoole\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();