PHP 函数并发编程在大型系统中的应用

php 函数并发编程能提升大型系统的性能，有两种实现方式：协程：轻量级，协作执行多个函数，使用 generator 实现。并行：重量级，使用进程或线程并行执行函数，使用 process 和 thread 类实现。

PHP 函数并发编程在大型系统中的应用

函数并发编程是指将函数作为独立任务执行的方法，从而提高大型系统的整体性能。PHP 提供了多种机制来实现函数并发编程，例如协程和并行。

协程

立即学习“PHP免费学习笔记（深入）”；

协程是 PHP 中一种轻量级的并发机制，它允许在单个 PHP 进程内执行多个函数，这些函数可以协作并暂停/恢复执行。协程通过 Generator 对象实现。

阿里云AI平台

阿里云AI平台

下载

实战案例：使用协程并发处理 HTTP 请求

use GuzzleHttp\Client;

function fetchPage(string $url): string
{
    $client = new Client();
    return $client->request('GET', $url)->getBody()->getContents();
}

function coroutineHttpRequests(): array
{
    $urls = ['https://example.com', 'https://example.com/about', 'https://example.com/contact'];
    $results = [];

    // Create a generator function
    function* coroutine() {
        foreach ($urls as $url) {
            $result = yield fetchPage($url);
            $results[] = $result;
        }
    }

    // Spawn the coroutine
    $coroutine = coroutine();

    // Iterate over the coroutine and yield results
    while ($coroutine->valid()) {
        $coroutine->send();
    }

    return $results;
}

$results = coroutineHttpRequests();
print_r($results);

并行

并行是一种更重量级的并发机制，它允许使用多个进程或线程并行执行函数。PHP 通过 Process 和 Thread 类支持并行。

实战案例：使用并行进行文件压缩

use ZipArchive;

function compressFile(string $filename): void
{
    $zip = new ZipArchive();
    if ($zip->open($filename . '.zip', ZipArchive::CREATE) === true) {
        foreach (glob($filename . '/*') as $file) {
            $zip->addFile($file, basename($file));
        }
        $zip->close();
    }
}

function parallelFileCompression(): void
{
    $files = ['file1', 'file2', 'file3'];

    // Create a Process object for each file
    $processes = array_map(function ($file) {
        return new Process("compressFile($file)");
    }, $files);

    // Start the processes
    foreach ($processes as $process) {
        $process->start();
    }

    // Wait for the processes to finish
    foreach ($processes as $process) {
        $process->wait();
    }
}

parallelFileCompression();