WyriHaximus / reactphp-child-process-messenger

benchmark/memory.php

<?php

const MB = 1048576;
const I = 100000;

function show_memory($message = '')
{
    echo '------------------------------------------', PHP_EOL;
    echo $message, PHP_EOL;
    echo '------------------------------------------', PHP_EOL;
    echo 'Current memory usage: ',      \memory_get_usage()          / MB, 'MB', PHP_EOL;
    echo 'Peak memory usage: ',         \memory_get_peak_usage()     / MB, 'MB', PHP_EOL;
    echo 'Current real memory usage: ', \memory_get_usage(true)      / MB, 'MB', PHP_EOL;
    echo 'Peak real memory usage: ',    \memory_get_peak_usage(true) / MB, 'MB', PHP_EOL;
}

show_memory('Bare init');

require \dirname(__DIR__) . '/vendor/autoload.php';

use React\EventLoop\Factory as EventLoopFactory;
use React\EventLoop\TimerInterface;
use WyriHaximus\React\ChildProcess\Messenger\Factory as MessengerFactory;
use WyriHaximus\React\ChildProcess\Messenger\Messages\Factory as MessagesFactory;
use WyriHaximus\React\ChildProcess\Messenger\Messenger;

show_memory('Begin');

$loop = EventLoopFactory::create();

The function React\EventLoop\Factory::create() has been deprecated: 1.2.0 See Loop::get() instead.

MessengerFactory::parentFromClass(\WyriHaximus\React\ChildProcess\Messenger\ReturnChild::class, $loop)->then(function (Messenger $messenger) use ($loop) {
    $messenger->on('error', function ($e) {
        echo 'Error: ', \var_export($e, true), PHP_EOL;
    });

    $i = 0;
    $loop->addPeriodicTimer(0.00001, function (TimerInterface $timer) use (&$i, $messenger, $loop) {
        if ($i >= I) {
            $loop->cancelTimer($timer);
            $messenger->softTerminate();

            show_memory('Completed messaging');

            $loop->addTimer(5, function () {
            });

            return;
        }

        $messenger->rpc(MessagesFactory::rpc('return', [
            'i' => $i,
            'time' => \time(),
        ]));

        $i++;
    });
})->done();

$loop->run();

show_memory('Done');

unset($loop);
$loop = null;

show_memory('Removed loop');

$cycles = \gc_collect_cycles();

show_memory('gc_collect_cycles: ' . $cycles);