OpenSwoole\Core\Process\Manager->setMsgQueueKey

Latest version: pecl install openswoole-22.1.2 | composer require openswoole/core:22.1.5

Declaration

<?php OpenSwoole\Core\Process\Manager->setMsgQueueKey(int $msgQueueKey)

Parameters

msgQueueKey

The message queue key when using system msg queue.

Return

Description

Set the msg queue key of the process manager.

You have to install OpenSwoole core library with composer require openswoole/core to use this feature.

Example

<?php
$pm = new OpenSwoole\Core\Process\Manager();
$atomic = new Atomic(0);
$pm->add(function (Pool $pool, int $workerId) use ($atomic) {
    usleep(100000);
    $atomic->wakeup();
});
$pm->add(function (Pool $pool, int $workerId) use ($atomic) {
    $atomic->wait(1.5);
    $pool->shutdown();
});
$pm->start();
Last updated on February 9, 2023