看看PHP 多进程处理任务

pcntl 模块（非 Unix 类系统不支持此模块）

一个 PHP 多进程简单例子大概是这个样子：

// 5 个子进程处理任务for ($i = 0;
     $i  5;
 $i++) {
        $pid = pcntl_fork();
    if ($pid == -1) {
            die("could not fork");
    }
 elseif ($pid) {
            echo "I'm the Parent $i\n";
    }
 else {
     // 子进程处理        echo "I'm the Child $i\n";
            // 业务处理        exIT($i);
 // 一定要注意退出子进程，否则 pcntl_fork() 会被子进程再 fork，带来处理上的影响。    }
}
// 等待子进程执行结束while (pcntl_waitpid(0, $status) != -1) {
        $status = pcntl_wexitstatus($status);
        echo "Child $status completed\n";
}
    复制代码

当然实际应用中我们不能够这样输出代码，不够健壮，也不够优雅，我所以找了个基于 pcntl 封装的扩展包来使用。

spatie/async - 基于 pcntl 封装的扩展包

以下是我使用 spatie/async 来优化一个多进程请求的例子

原代码（耗时 20s 左右）- github.COM/guanguans/m…

/** * @param string $keyword * * @return array */public function seArchAll(string $keyword): array{
        $songAll = [];
        foreach ($this->
platforms as $platform) {
            $songAll = array_merge($songAll, $this->
    search($platform, $keyword));
    }
        return $songAll;
}
/** * @param string $platform * @param string $keyword * * @return mixed */public function search(string $platform, string $keyword){
        $meting = $this->
    getMeting($platform);
        $songs = json_decode($meting->
    format()->
    search($keyword), true);
        foreach ($songs as $key =>
     &
$song) {
            $detail = json_decode($meting->
    format()->
    url($song['url_id']), true);
        if (empty($detail['url'])) {
                unset($songs[$key]);
        }
            $song = array_merge($song, $detail);
    }
        unset($song);
        return $songs;
}
    复制代码

改进后（耗时 4s 左右）- github.com/guanguans/m…

/** * @param string $keyword * * @return array */public function searchAll(string $keyword): array{
        $songAll = [];
        $pool = Pool::create();
        foreach ($this->
platforms as $platform) {
            $pool->
add(function () use ($platform, $keyword) {
                return $this->
    search($platform, $keyword);
        }
    , $this->
    getSerializedOutput())->
    then(function ($output) use (&
$songAll) {
                $songAll = array_merge($songAll, $output);
        }
    )->
catch(function (\Throwable $exception) {
                exit($exception->
    getMessage());
        }
    );
    }
        $pool->
    wait();
        return $songAll;
}
/** * @return mixed */public function search(string $platform, string $keyword){
        $meting = $this->
    getMeting($platform);
        $songs = json_decode($meting->
    format()->
    search($keyword), true);
        $pool = Pool::create();
        foreach ($songs as $key =>
     &
$song) {
            $pool->
add(function () use ($meting, $song) {
                return json_decode($meting->
    format()->
    url($song['url_id']), true);
        }
    )->
    then(function ($output) use (&
    $songs, &
$song, $key) {
                $song = array_merge($song, $output);
            if (empty($song['url'])) {
                    unset($songs[$key]);
            }
        }
    )->
catch(function (\Throwable $exception) {
                exit($exception->
    getMessage());
        }
    );
    }
        unset($song);
        $pool->
    wait();
        return $songs;
}
    复制代码

想了解更多编程学习，敬请关注php培训栏目！

以上就是看看PHP 多进程处理任务的详细内容，更多请关注其它相关文章！

声明：本文内容由网友自发贡献，本站不承担相应法律责任。对本内容有异议或投诉，请联系2913721942#qq.com核实处理，我们将尽快回复您，谢谢合作！