【亿码酷站-编程开发教程】收集全网优质教程及源码资源!
全网优质软件开发、平面设计等教程及精品源码资源一站可得,www.ymkuzhan.com!
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中文网如有侵权请联系admin#tyuanma.cn删除
如何设置mysql服务开机不启动?
声明: 本文章由【亿码酷站】整理自网络!如有侵权,请邮件联系 ymkuzhan@126.com 删除。本站发布的文章及附件仅限用于学习和研究目的;不得将上述内容用于商业或非法用途,否则后果请用户自负。
本站信息来自网络,版权争议与本站无关。您必须在下载后的24个小时之内,从您的电脑中彻底删除上述内容。如果您喜欢该程序,请支持正版软件,购买注册,得到更好的正版服务。如有侵权请邮件与我们联系处理。
赞助本站仅为维持服务器日常运行并非购买程序及源码费用因此不提供任何技术支持,如需商用请购买正版!
本站资源如无特殊说明解压密码一律为www.ymkuzhan.com
本站信息来自网络,版权争议与本站无关。您必须在下载后的24个小时之内,从您的电脑中彻底删除上述内容。如果您喜欢该程序,请支持正版软件,购买注册,得到更好的正版服务。如有侵权请邮件与我们联系处理。
赞助本站仅为维持服务器日常运行并非购买程序及源码费用因此不提供任何技术支持,如需商用请购买正版!
本站资源如无特殊说明解压密码一律为www.ymkuzhan.com