PHP Web应用无扩展实现方法并行执行的可行性及方案确认

首先直接给你结论：你提到的amphp/parallel确实能在不依赖pthread或pcntl扩展的情况下实现真正的并行处理，完全能满足你同时执行test1()（数据库查询）和test2()（耗时循环）并获取结果的需求。

先澄清一个误区：“无扩展则无法并行”是错的 #

PHP实现并行不一定需要扩展——它可以通过创建独立的子进程来实现，每个子进程拥有自己的PHP解释器实例，完全独立运行。amphp/parallel就是基于这个原理工作的：它会根据你的操作系统自动选择合适的方式（类Unix系统用进程fork，Windows用exec创建子进程），不需要你手动处理底层细节，封装得非常友好。

而你提到的“任务排队”是协程的特点（单线程内切换执行），但amphp/parallel不是协程，它是真正的多进程并行，所以两个任务会同时占用CPU资源运行，总耗时等于耗时最长的那个任务（而不是两个任务时间相加）。

针对你的需求修改代码示例 #

下面是适配你test1()和test2()的完整代码，直接可以在Web环境下运行（只要主机允许创建子进程）：

<?php
require __DIR__ . '/../vendor/autoload.php';
use Amp\Parallel\Worker;
use Amp\Promise;

// 模拟数据库查询的方法
function test1() {
    // 注意：子进程无法继承父进程的数据库连接，需要在函数内部重新建立
    $pdo = new PDO('mysql:host=localhost;dbname=your_db', 'user', 'pass');
    $stmt = $pdo->query('SELECT * FROM users WHERE id = 1');
    $result = $stmt->fetch(PDO::FETCH_ASSOC);
    $pdo = null; // 关闭连接
    
    // 模拟查询耗时
    sleep(2);
    return $result;
}

// 模拟耗时循环的方法
function test2() {
    $total = 0;
    for ($i = 0; $i < 10000000; $i++) {
        $total += $i;
    }
    return "循环计算结果：{$total}";
}

// 将两个任务加入并行队列
$promises = [
    'db_result' => Worker\enqueueCallable('test1'),
    'loop_result' => Worker\enqueueCallable('test2'),
];

// 等待所有任务完成，获取结果
try {
    $results = Promise\wait(Promise\all($promises));
    
    // 后续代码使用两个方法的返回结果
    var_dump($results['db_result']);
    echo $results['loop_result'] . PHP_EOL;
} catch (\Exception $e) {
    echo "执行出错：" . $e->getMessage() . PHP_EOL;
}

关键注意事项 #

• 资源隔离：子进程和父进程是完全独立的，所以像数据库连接、文件句柄这类资源无法直接继承。你需要在test1()内部重新建立数据库连接，执行完后关闭。
• 数据序列化：传递给子进程的参数和子进程返回的结果需要可序列化（PHP的serialize()支持的类型）。如果你的方法依赖复杂对象，要确保对象实现了Serializable接口或者可以被自动序列化。
• Web环境限制：部分共享主机可能禁用了进程创建相关的函数（比如pcntl_fork、exec），这种情况下amphp/parallel无法工作。如果是VPS或云服务器，一般没问题。
• Symfony/Process的替代方案：其实Symfony/Process也可以在Web环境使用，只是它更适合执行外部命令或独立脚本。你可以把test1()和test2()写成单独的PHP脚本，然后用Process类启动两个脚本并行执行，最后读取输出结果。但amphp/parallel更直接，不需要拆分脚本。

总结 #

amphp/parallel完全符合你的需求：无需扩展、真正并行执行任务、能获取返回结果。只要你的Web环境允许创建子进程，就可以放心使用。

内容的提问来源于stack exchange，提问作者SkyRar