PHP多线程如何实现线程池 - 问答

在 PHP 中，实现线程池的最佳方法是使用 pthreads 扩展。但是，pthreads 扩展仅支持 CLI（命令行接口）模式，不适用于 Web 环境。因此，如果你需要在 Web 环境中实现线程池，可以考虑使用第三方库，如 parallel 或 amphp/amp。

以下是使用 pthreads 扩展实现线程池的示例：

首先，确保已安装 pthreads 扩展。在 Ubuntu 系统中，可以使用以下命令安装：

sudo apt-get install php-pthreads

创建一个名为 ThreadPool.php 的文件，并添加以下代码：

<?php
class ThreadPool {
    private $threadCount;
    private $jobs = [];
    private $threads = [];
    private $running = true;

    public function __construct($threadCount) {
        if (!extension_loaded('pthreads')) {
            throw new Exception('pthreads extension not loaded.');
        }
        $this->threadCount = $threadCount;
    }

    public function addJob(callable $job) {
        $this->jobs[] = $job;
    }

    public function start() {
        for ($i = 0; $i < $this->threadCount; $i++) {
            $thread = new Thread(new Job($this->jobs));
            $thread->start();
            $this->threads[] = $thread;
        }
    }

    public function join() {
        foreach ($this->threads as $thread) {
            $thread->join();
        }
    }
}

class Job extends Thread {
    private $jobs;

    public function __construct(array $jobs) {
        $this->jobs = $jobs;
    }

    public function run() {
        foreach ($this->jobs as $job) {
            $job();
        }
    }
}

// 示例任务
function task() {
    echo "Task executed by thread " . Thread::currentThread()->getId() . PHP_EOL;
}

// 创建线程池并添加任务
$threadPool = new ThreadPool(3);
for ($i = 0; $i < 10; $i++) {
    $threadPool->addJob(function() use ($i) {
        task();
    });
}

// 启动线程池并等待任务完成
$threadPool->start();
$threadPool->join();
?>

在这个示例中，我们创建了一个名为 ThreadPool 的类，它接受一个参数 $threadCount，表示线程池中的线程数量。我们还创建了一个名为 Job 的类，它实现了 Thread 类，并在其 run 方法中执行任务。

要使用这个线程池，只需创建一个 ThreadPool 实例，添加任务，然后启动线程池并等待任务完成。在这个示例中，我们添加了 10 个任务和 3 个线程，因此每个线程将执行 3 个任务。

0 赞

0 踩