swoole.php

<?php


use Swoole\Http\Server;

$serv = new swoole_http_server('0.0.0.0', 9501);


$serv->set(array(
    'task_worker_num' => 10,
    'task_max_request' => 1
));

$serv->on('request', function ($request, $response) use ($serv) {
    $task_id = $serv->task("Async");
    $response->header('Content-Type', 'text/html; charset=utf-8');
    $response->end('<h1>Hello Swoole. #' . rand(1000, 9999) . '</h1>');
});

$serv->on('Start', function (Server $serv) {

    sleep(1);
    $conn_list = $serv->connection_list(0, 100);

    swoole_process::signal(SIGQUIT, function($signo) use ($serv) {
        echo "QUIT ON MASTER: $signo\n";

        foreach (range(0, 10) as $worker_id) {
            $serv->task($worker_id);
        }

         swoole_process::wait();

    });

});


$serv->on('Task', function (Server $serv, $task_id, $from_id, $data) {

    require __DIR__.'/foo.php';


    echo "start work\n";

    foreach (range(0, 100) as $i) {
        echo "try to finish my work";
        sleep(1);
    }

//    sleep(10);

    echo "finished {$GLOBALS['worker_id']} work\n";

    $serv->finish("$data -> OK");
});

$serv->on('workerStart', function(Server $serv, $worker_id) {

    $GLOBALS['worker_id'] = $worker_id;


    echo "Worker Start\n";
});

$serv->on('Finish', function ($serv, $task_id, $data) {
    echo "AsyncTask[$task_id] Finish: $data".PHP_EOL;
});
$serv->start();