PHP多线程实现与并行任务模拟方法

PHP虽不原生支持多线程，但可通过多种成熟方案高效实现并发与并行任务处理：借助pthreads扩展（需ZTS版PHP）进行真正的多线程编程；利用pcntl_fork在类Unix系统下创建子进程模拟并行；采用ReactPHP或Amp等异步I/O库以事件驱动或协程方式实现高并发、非阻塞操作；还可通过cURL多句柄批量发起网络请求，显著提升I/O密集型任务效率——无论您需要加速数据处理、并行调用API，还是构建响应式CLI工具，这些方法都能在macOS等主流环境中稳定落地，让PHP轻松应对现代高性能场景。

如果您希望在PHP中实现多线程或模拟并行处理任务，以提升执行效率或同时处理多个耗时操作，可以采用多种技术手段。由于PHP本身并不原生支持多线程，但可以通过扩展或系统级调用模拟并发行为。

本文运行环境：MacBook Pro，macOS Sonoma

一、使用pthreads扩展（仅限于ZTS版本PHP）

pthreads是一个允许PHP在支持线程的安全模式下创建和使用线程的扩展，主要用于CLI模式下的多线程编程。

1、确保您的PHP是以ZTS（Zend Thread Safety）方式编译，并已安装pthreads扩展。

2、定义一个继承自Thread的类，并重写run方法：

class WorkerTask extends Thread {
private $data;
public function __construct($data) {
$this->data = $data;
}
public function run() {
// 模拟耗时操作
echo "Processing " . $this->data . "\n";
sleep(2);
}
}

3、实例化多个线程并启动：

$t1 = new WorkerTask("Task 1");
$t2 = new WorkerTask("Task 2");
$t1->start();
$t2->start();
$t1->join();
$t2->join();

二、利用pcntl_fork创建子进程模拟并行

通过pcntl扩展提供的pcntl_fork函数，可以在类Unix系统上创建子进程，从而实现任务的并行执行。

1、检查PHP是否启用了pcntl扩展，该扩展通常不支持Web服务器环境，仅适用于CLI。

2、使用pcntl_fork()生成子进程：

$pid = pcntl_fork();
if ($pid == -1) {
die('Could not fork');
} else if ($pid == 0) {
// 子进程执行逻辑
echo "Child process: " . getmypid() . "\n";
sleep(2);
exit(0);
} else {
// 父进程继续执行
echo "Parent waiting for child...\n";
}

3、父进程等待子进程结束：

pcntl_wait($status); // 阻塞等待子进程退出

三、使用ReactPHP实现异步并发处理

ReactPHP是一个事件驱动的库，可用于构建非阻塞I/O应用，适合处理大量并发I/O操作。

1、通过Composer安装ReactPHP：

composer require react/react

2、创建一个事件循环并添加异步任务：

require 'vendor/autoload.php';
$loop = React\EventLoop\Factory::create();

$loop->addTimer(2, function () {
echo "Task 1 completed\n";
});

$loop->addTimer(2, function () {
echo "Task 2 completed\n";
});

$loop->run();

四、使用amphp/amp进行协程式并发

Amp是一个基于协程的PHP库，提供async/await语法来编写非阻塞代码。

1、安装amphp/amp库：

composer require amphp/amp

2、定义异步任务并并行执行：

Amp\Loop::run(function () {
$promises = [];

for ($i = 1; $i $promises[] = Amp\call(function () use ($i) {
echo "Starting task $i\n";
yield Amp\delay(2000); // 模拟延迟
echo "Completed task $i\n";
});
}

yield Amp\Promise\all($promises);
});

五、通过cURL多句柄实现HTTP请求并行

当需要并行发起多个HTTP请求时，可使用curl_multi_init来避免串行等待。

1、初始化多个cURL句柄并加入multi handler：

$ch1 = curl_init('https://httpbin.org/delay/2');
$ch2 = curl_init('https://httpbin.org/delay/2');
curl_setopt($ch1, CURLOPT_RETURNTRANSFER, true);
curl_setopt($ch2, CURLOPT_RETURNTRANSFER, true);

$mh = curl_multi_init();
curl_multi_add_handle($mh, $ch1);
curl_multi_add_handle($mh, $ch2);

2、执行多请求并轮询状态：

$active = null;
do {
$status = curl_multi_exec($mh, $active);
curl_multi_select($mh);
} while ($active > 0);

$response1 = curl_multi_getcontent($ch1);
$response2 = curl_multi_getcontent($ch2);

curl_multi_remove_handle($mh, $ch1);
curl_multi_remove_handle($mh, $ch2);
curl_multi_close($mh);

今天关于《PHP多线程实现与并行任务模拟方法》的内容就介绍到这里了，是不是学起来一目了然！想要了解更多关于PHP函数的内容请关注golang学习网公众号！