pcntl_fork 然后 pcntl_exec 或 pcntl_exec 然后 pcntl_fork

Question

说明： 我正在创建的应用程序的一部分需要检查数千条记录并及时对它们采取行动。因此，对于每条记录，我都想分叉一个新流程。但是，我需要一个数据库连接来对该记录进行更多检查。据我了解，孩子继承了数据库连接。所以后续的fork会出现DB错误。

我以为我可以 pcntl_exec('php /path/script.php');然后是 pcntl_fork ，这样调用进程就不会被阻塞。

或者我可以在子进程中使用 pcntl_fork 然后 pcntl_exec 。或者也许我应该使用 exec() 而不是 pcntl_exec()。

我的问题：这两种订单都有缺点或优点吗？

注释： 也许我正在想象这个问题，因为我认为调用 php 进程会等待 pcntl_exec 返回。但这不是文档所说的：

出错时返回 FALSE，成功时不返回。

函数如何有时返回值而其他时候不返回值？这听起来像是写得不好的文档。

fahadsadah 的评论指出：

一旦执行的进程结束，控制权返回到网络服务器进程。

如果是这样的话，那么我需要分叉。

编辑：为困惑的人提供的代码 - 包括我;)

<?php

class Process
{

    public function __construct($arg = false)
    {
        if ($arg == "child")
        {
            $this->act();
        }
        else
        {
            $this->run();
        }
    }

    public function run()
    {
        echo "parent before fork:", getmypid(), PHP_EOL;
        $pid = @ pcntl_fork();
        echo $pid, PHP_EOL;

        if ($pid == -1)
        {
            throw new Exception(self::COULD_NOT_FORK);
        }
        if ($pid)
        {
        // parent
            echo "parent after fork:", getmypid(), PHP_EOL;
        }
        elseif ($pid == 0)
        {
        // child
            echo "child after fork:", getmypid(), PHP_EOL;
            //echo exec('php Process.php child');
            echo pcntl_exec('/usr/bin/php', array('Process.php', 'child'));
        }
        return 0;
    }

    private function act()
    {
        sleep(1);
        echo "forked child new process:", getmypid(), PHP_EOL;
        return 0;
    }
}

$proc = new Process($argv[1]);

如果您取消注释 exec 并注释 pcntl_exec，您将看到 pcntl_exec 替换了该进程。我猜这可以节省一些资源。

Answer 1

这确实令人困惑 - 您正在尝试应用非常复杂的技术 - 但您以完全错误的方式应用它们。

fork 创建当前进程的新的运行副本。 Exec 启动一个新进程。您不会同时使用它们来启动单个进程。

但在我开始解释如何正确使用 fork 和 exec 之前，我应该指出它们不是解决这个问题的正确工具。

应尽可能避免批处理。数据通常以有限的速率到达（尽管该速率可能是随机的）——通常避免批处理的正确方法是同步或通过队列处理请求。在批处理不可避免的情况下，并行化和/或流水线处理通常可以提高吞吐量。虽然有许多复杂的方法可以实现这一点（例如映射减少），但简单地对数据进行分片通常就足够了。虽然您的基本想法相当于将数据分片成单个片段，但是：

1) 比处理小批量的效率要低

2) 很难限制系统的资源消耗（如果您生成 500 个进程，而您的 DBMS 仅支持 200 个进程，该怎么办？并发连接？）

假设您无法同步处理处理并且运行具有多个订阅者的队列是不切实际的，我建议将数据分成（有限数量的）较小的批次并生成进程来处理这些。请注意，popen()、proc_open() 和 pcntl_fork() 在生成进程的执行期间不会阻塞。 （提示 - 使用模数运算符）

如果你想从 HTTP 请求启动处理（或者有其他原因在单独的会话组中运行它们），然后在 google 上搜索“PHP 长时间运行的进程 setid”。

Answer 2

这没有道理。一旦你执行了 exec()，你就会运行不同的代码，所以你不能在之后 fork()。 成功后不会返回。

Answer 3

现在 fork 和 exec 已经被定义了，fork 不会做你想要的事情。它将把当前脚本环境的所有内容复制到新空间，包括文件描述符指针。是的，这是正确的 - 子级与父级共享相同的文件描述符。

想象一下使用维护自己的文件描述符的 mysql 扩展时会造成的严重破坏;-)