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

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);

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();