PHP ???????? ????? ??

PHP ???????? ????? ?? ???? ?? ???? ??? ?? ????. ?????? ?? ?? ???, pthreads ??? ???? ?? ??? ? ?? ??? ????.

pthreads ??

pthreads ??? ???? ????? PHP ??????? ?? ? ?? ??? ?????. ??? ??, ???, ??? ?? ???? API? ?????. ?, ? ?? ??? ? ?? ????? ??? ? ??? CLI ?? ????????? ????? ?? ???? ???.

??: ?? ?? ??

?? ?? ?? ?????. pthreads ??? ??? ?? ?? ?:

• ?? ??: pthreads ?? ????? ?? ???? ?? ?? ??? ?????.
• ?? ?? ??: pthread? ? ?? ???? ??? ? ????.
• PHP ?? ???: pthreads( v3)? PHP 7.2?? ???? ?.

?? ??

??? pthreads ??? ???? ?? ???? ???? ??? ????.

#!/usr/bin/php
<?php
class AsyncOperation extends Thread {

    public function __construct($arg) {
        $this->arg = $arg;
    }

    public function run() {
        if ($this->arg) {
            $sleep = mt_rand(1, 10);
            printf('%s: %s  -start -sleeps %d' . "\n", date("g:i:sa"), $this->arg, $sleep);
            sleep($sleep);
            printf('%s: %s  -finish' . "\n", date("g:i:sa"), $this->arg);
        }
    }
}

// Create a stack of threads
$stack = array();

// Initiate multiple threads
foreach ( range("A", "D") as $i ) {
    $stack[] = new AsyncOperation($i);
}

// Start the threads
foreach ( $stack as $t ) {
    $t->start();
}

? ????? ???? ??? ?? ??? ? ? ????. ?? ???? ??? ???? ???? PHP? ????? ??? ?????. pthreads.

?? ?? ??

??? ?? ????? ?? pthreads ??? ???? ????.

error_reporting(E_ALL);
class AsyncWebRequest extends Thread {
    public $url;
    public $data;

    public function __construct($url) {
        $this->url = $url;
    }

    public function run() {
        if (($url = $this->url)) {
            $this->data = file_get_contents($url);
        } else
            printf("Thread #%lu was not provided a URL\n", $this->getThreadId());
    }
}

$t = microtime(true);
$g = new AsyncWebRequest(sprintf("http://www.google.com/?q=%s", rand() * 10));
// starting synchronization 
if ($g->start()) {
    printf("Request took %f seconds to start ", microtime(true) - $t);
    while ( $g->isRunning() ) {
        echo ".";
        usleep(100);
    }
    if ($g->join()) {
        printf(" and %f seconds to finish receiving %d bytes\n", microtime(true) - $t, strlen($g->data));
    } else
        printf(" and %f seconds to finish, request failed\n", microtime(true) - $t);
}

? ????? pthreads ??? ??? ??? ? ??. ?? ??? ??? ???? ?? ???????? ?????? ??? ??? ???? ? ??? ?????.

??

pthreads ??? PHP ???????? ?????? ???? ??? ?????. ? ?? ?? ??? ????. ??? ???? ??? ???? ?? ?? ??? ?? pthread? ???? ???? ???.

? ??? pthreads ??? ???? PHP ???????? ?????? ??? ??? ? ?????? ?? ?????. ??? ??? PHP ??? ????? ?? ?? ??? ?????!