class Command {
    private $descriptorspec;
    
    private $output = '';
    
    public function __construct(){
        $this->descriptorspec = [
            0 => ['pipe', 'r'], // stdin
            1 => ['pipe', 'w'], // stdout
            2 => ['pipe', 'w'], // stderr
        ];
    }
    
    public function output(): string{
        return $this->output;
    }
    
    public function exec(string $syntax): string{
        $process = proc_open($syntax, $this->descriptorspec, $pipes);
        
        $this->output = stream_get_contents($pipes[1]);
        fclose($pipes[1]);
        
        $stderr = stream_get_contents($pipes[2]);
        fclose($pipes[2]);
        
        proc_close($process);
        
        return $stderr;
    }
}

$Cmd = new Command;
$Cmd->exec('tesseract ...');

php

multithreading

tesseract

人脸识别特惠活动

精准实时的人脸检测、分析、识别等服务，在线、离线满足多样需求，可应用于智慧零售、智慧社区、在线娱乐等多种应用场景

回答 3

Stack Overflow用户

发布于 2016-08-10 14:07:42

不要这样做。PHP对多线程的支持真的很糟糕。相反，请使用多进程。使用proc_open & co。-- http://php.net/manual/en/function.proc-open.php

票数 0

Stack Overflow用户

发布于 2016-08-10 14:11:26

您不需要使用多线程。要运行6个工作进程，而不需要与父进程同步-您可以使用proc_open

多线程更快，占用的资源更少(它没有单独的命名空间)，你可以比work多运行4倍，但多线程需要用非ZTS构建PHP (一些扩展不能与非ZTS一起工作)，并且需要一些你能理解的pthread模型。

举个例子：

我们使用proc_open创建了6个worker，并使用基础进程侦听孩子(我使用我的包装器，使用Ev或事件库或不使用它们) (child-processes)，也许你会喜欢包装器reactphp (child-processes)

    $child = new ChildProcesses();
    $child->add('<system command>');
    $child->add('<system command>');
    $child->add('<system command>');
    $child->add('<system command>');
    $child->add('<system command>');
    $fails = $child->check(null, function(ChildProcess $process) {
        echo 'Error with chld process';
    });

或者使用pthread阅读官方文档。您需要在非ZTS中重新编译PHP，并安装pthread扩展。对于您的问题，我将使用Pool

您需要查看此页面中的第一个示例Pool pthreads

更新：

如果你需要所有的时间--6个工人。您需要创建六个监听器。进程之间的通信使用zmq或rabbitmq、gearman或其他不同的队列。你的进程永远不会死，倒下的进程会被监督者抬起来。

例如：

$loop = Factory::create();
$context = new Context($loop));
$context->getSocket(\ZMQ::SOCKET_SUB);
$context->connect($host);
$context->subscribe('you_queue');
$context->on('messages', function($messages){
    // get specific data and run operation
});
$loop->run();

注意，zmq不是完全排队的。

It not save message
react / zmq使用EventLib，所以实际上我的示例是zmq

您需要使用Gearman或RabbitMQ -您的任务具有理想的功能

尊敬的格言

票数 0

Stack Overflow用户

发布于 2016-08-20 15:56:03

我写了一个例子(基于child-processes)。这应该可以解决您的问题：

这是parent.php:

$child = new ChildProcesses();
$child->addProcessInstance(new \TkachInc\ChildProcesses\ChildProcess('php worker.php -w1'));
$child->addProcessInstance(new \TkachInc\ChildProcesses\ChildProcess('php worker.php -w2'));
$child->addProcessInstance(new \TkachInc\ChildProcesses\ChildProcess('php worker.php -w3'));
$child->addProcessInstance(new \TkachInc\ChildProcesses\ChildProcess('php worker.php -w4'));
$child->addProcessInstance(new \TkachInc\ChildProcesses\ChildProcess('php worker.php -w5'));
$child->addProcessInstance(new \TkachInc\ChildProcesses\ChildProcess('php worker.php -w6'));
$child->daemon();

和您的worker.php (我添加了示例输出，您需要删除它)：

$options = getopt("w:");
if(isset($options['w']))
{
    echo $options['w'].PHP_EOL;

    switch ($options['w'])
    {
        case "1":
            sleep(5);
            break;
        case "2":
            sleep(5);
            break;
        case "3":
            sleep(7);
            break;
        case "4":
            sleep(5);
            break;
        case "5":
            sleep(7);
            break;
        case "6":
            sleep(5);
            break;
    }
}

// your logic to receive from database and write to database