PHP-FPM 和 pthreads

Question

我正在使用 PHP-FPM 运行 Phalcon 应用程序，并且刚刚安装了 pthreads，因此我可以开始异步运行任务。我目前有 pthreads 使用命令行界面工作:

<?php

/**
 * Author: Abu Ashraf Masnun
 * URL: http://masnun.me
 */

class WorkerThreads extends Thread
{
    private $workerId;

    public function __construct($id)
    {
        $this->workerId = $id;
    }

    public function run()
    {
        usleep(2000000); // 2 seconds
        echo "Worker {$this->workerId} ran" . PHP_EOL;
    }
}

// Worker pool
$workers = [];

// Initialize and start the threads
foreach (range(0, 5) as $i) {
    $workers[$i] = new WorkerThreads($i);
    $workers[$i]->start();
}

// Let the threads come back
foreach (range(0, 5) as $i) {
    $workers[$i]->join();
}

die('finished');

^^ 所有这些都可以从 shell 运行 php test.php。

但是我无法使用快速流程管理器让这个示例运行。我有一个 Controller 初始化一个线程对象并调用 start()，但是 run() 方法中的逻辑都没有按预期执行。

Controller :

<?php

public function indexAction()
{

$threads=[];
for ( $i = 0; $i < 2; $i++ )
{
    $threads[$i] = new AsyncThread();
    $a = $threads[$i]->start();
    $b = $threads[$i]->isStarted();
    Phalcon\DI::getDefault()->get('logger')->log(json_encode($a));
    Phalcon\DI::getDefault()->get('logger')->log(json_encode($b));
}
for ( $i = 0; $i < 2; $i++ )
{
    $threads[$i]->join();
}
die('done');

异步线程.php:

<?php

class AsyncThread extends Thread
{

    public function __construct()
    {
        Phalcon\DI::getDefault()->get('logger')->log( 'construct' );
    }

    public function run()
    {
        usleep(2000000); // 2 seconds
        Phalcon\DI::getDefault()->get('logger')->log( 'running' );
    }

}

运行时我的日志显示:

[Tue, 17 Nov 15 22:10:43 +0000][INFO][][] construct
[Tue, 17 Nov 15 22:10:43 +0000][INFO][][] true
[Tue, 17 Nov 15 22:10:43 +0000][INFO][][] true
[Tue, 17 Nov 15 22:10:43 +0000][INFO][][] construct
[Tue, 17 Nov 15 22:10:43 +0000][INFO][][] true
[Tue, 17 Nov 15 22:10:43 +0000][INFO][][] true

我希望看到异步“运行”日志，但它根本不会记录。

我的目标是获得一个使用 PHP-FPM 的 posix 线程的 hello world 示例，这样我就可以开始构建一个深思熟虑的解决方案来满足我的需求。

Answer 1

如果您使用的是旧版本的 PHP 和 pthreads (< PHP7)，那么线程将在没有正确设置 stdout 的情况下运行(因为 FPM 和 Zend 无法设置它)。

最新版本的 pthreads(适用于 PHP7)禁止在除 CLI 以外的任何地方执行。

无法在应用程序的前端明智地使用线程。

考虑创建合理数量线程的 Controller 的情况，比方说 8。如果 100 个客户端同时请求 Controller ，您将要求您的硬件同时执行 800 个内核线程，微小 流量。

这种架构无法扩展。

您一直使用异步这个词代替并行，这让我觉得您可能根本不需要线程。

如果手头的任务是发出一些异步 Web 请求，那么最好的方法是使用非阻塞 I/O，而不是线程。

如果您错误地使用了异步这个词，而实际上是指并行，那么您将需要为应用程序的那些需要与 Web 服务器扩展的部分以及应用程序的那些需要找到另一种方法并行并发以相互通信。