Submit a Pull Request Report a Bug

    Класс parallel\Runtime

    (0.8.0)

    Объекты во временя выполнения

    Каждая среда выполнения представляет собой один поток PHP, поток создаётся (и загружается) при создании. Затем поток ожидает, пока задачи будут запланированы: запланированные задачи будут выполняться FIFO, а затем поток возобновит ожидание, пока не будут запланированы другие задачи или пока он не будет закрыт, убит или уничтожен в соответствии с обычными правилами области видимости объектов PHP.

    Внимание

    Когда среда выполнения уничтожается обычными правилами области видимости объектов PHP, она сначала выполняет все запланированные задачи и при этом блокирует добавление новых.

    Начальная загрузка во время выполнения

    Когда создаётся новая среда выполнения, она не разделяет код с потоком (или процессом), который её создал. Это означает, что в нём не загружены те же классы и функции, а также не установлен один и тот же автозагрузчик. В некоторых случаях желательна очень лёгкая среда выполнения, потому что задачи, которые будут запланированы, не нуждаются в доступе к коду в родительском потоке. В тех случаях, когда задачам нужен доступ к одному и тому же коду, достаточно установить автозагрузчик в качестве начальной загрузки.

    Замечание:

    Предварительная загрузка может использоваться вместе с параллельной, в этом случае предварительно загруженный код доступен без начальной загрузки.

    Обзор классов

    final class parallel\Runtime {
    /* Создание */
    public __construct()
    public __construct(string $bootstrap)
    /* Выполнение */
    public run(Closure $task): ?Future
    public run(Closure $task, array $argv): ?Future
    /* Присоединение */
    public close(): void
    public kill(): void
    }

    Содержание

    add a note add a note

    User Contributed Notes 1 note

    up
    9
    Luciano Vettoretti
    4 years ago
    basic-multithreading-test.php

    <?php
    use parallel\Runtime;
    use     parallel\Channel;

    $test = "this var is not accesible in a thread";

    // this function will be the threads
    $thread_function = function (int $id, Channel $ch) {
            // delay the first thread to simulate better multithreading
        // second thread always finishes first
            $sleep = ($id == 2) ? 1 : 2;
            sleep($sleep);

            // print thread id
        // so it's clear second thread goes first
        // and also you can make sure multithreading is working
            var_dump("thread $id sleep $sleep");

            // try to capture globals, but it's not possible
            echo '$GLOBALS["test"] = ';
        @    var_dump($GLOBALS["test"]);

            // the only way to share data is between channels
            $ch->send($sleep);
    };

    try {
            // each runtime represents a thread
            $r1 = new Runtime();
            $r2 = new Runtime();

            // channel where the date will be sharead
            $ch1 = new Channel();

            // args that will be sent to $thread_function
            $args = array();
            $args[0] = null;
            $args[1] = $ch1;

            // running thread 1
            $args[0] = 1;
            $r1->run($thread_function, $args);

            // running thread 2
            $args[0] = 2;
            $r2->run($thread_function, $args);

            // receive data from channel
            $x = $ch1->recv();
            $y = $ch1->recv();

            // close channel
            $ch1->close();

        echo     "\nData received by the channel: $x and $y";
    } catch (    Error $err) {
        echo     "\nError:", $err->getMessage();
    } catch (    Exception $e) {
        echo     "\nException:", $e->getMessage();
    }
    add a note add a note
    To Top