在 PHP 應(yīng)用程序中實(shí)現(xiàn)多線(xiàn)程

關(guān)于在 PHP 應(yīng)用程序中實(shí)現(xiàn)多線(xiàn)程的可能性一直有持續(xù)的討論。雖然這看起來(lái)不切實(shí)際，但有一種方法可以使用 pthreads 擴(kuò)展來(lái)實(shí)現(xiàn)這一目標(biāo)。

pthreads 擴(kuò)展

pthreads 擴(kuò)展是一個(gè)功能強(qiáng)大的工具，允許開(kāi)發(fā)人員創(chuàng)建多線(xiàn)程 PHP 應(yīng)用程序。它提供了一個(gè)面向?qū)ο蟮?API，用于創(chuàng)建、同步和管理線(xiàn)程。但是，需要注意的是，此擴(kuò)展不能在 Web 服務(wù)器環(huán)境中使用，并且僅限于基于 CLI 的應(yīng)用程序。

警告：擴(kuò)展限制

了解這一點(diǎn)至關(guān)重要以下與 pthreads 擴(kuò)展相關(guān)的警告：

• 棄用： pthreads 擴(kuò)展是
• 服務(wù)器限制： pthreads 不能在 Web 服務(wù)器環(huán)境中使用。
• PHP 版本兼容性： pthreads (v3)僅兼容 PHP 7.2 及以上版本。

示例實(shí)現(xiàn)

下面是一個(gè)使用 pthreads 擴(kuò)展創(chuàng)建多個(gè)線(xiàn)程的簡(jiǎn)單示例：

#!/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();
}

執(zhí)行此腳本時(shí)，您會(huì)注意到多個(gè)線(xiàn)程被同時(shí)創(chuàng)建和執(zhí)行，演示了多線(xiàn)程-PHP 與 pthread 的線(xiàn)程功能。

真實(shí)用例

這里是一個(gè)示例在實(shí)際場(chǎng)景中使用 pthreads 擴(kuò)展的示例：

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 擴(kuò)展發(fā)出異步 Web 請(qǐng)求。它展示了多線(xiàn)程如何提高需要同時(shí)處理多個(gè)任務(wù)的應(yīng)用程序的性能。

結(jié)論

pthreads 擴(kuò)展提供了一種在 PHP 應(yīng)用程序中實(shí)現(xiàn)多線(xiàn)程的方法，盡管它有一些限制。但是，開(kāi)發(fā)人員應(yīng)該了解這些警告，并考慮 pthread 對(duì)其特定用例的適用性。

以上是如何使用 pthreads 擴(kuò)展在 PHP 應(yīng)用程序中實(shí)現(xiàn)多線(xiàn)程？的詳細(xì)內(nèi)容。更多信息請(qǐng)關(guān)注PHP中文網(wǎng)其他相關(guān)文章！