PHP中怎么利用多進程處理任務(wù)，針對這個問題，這篇文章詳細介紹了相對應(yīng)的分析和解答，希望可以幫助更多想解決這個問題的小伙伴找到更簡單易行的方法。

創(chuàng)新互聯(lián)公司服務(wù)項目包括東風(fēng)網(wǎng)站建設(shè)、東風(fēng)網(wǎng)站制作、東風(fēng)網(wǎng)頁制作以及東風(fēng)網(wǎng)絡(luò)營銷策劃等。多年來，我們專注于互聯(lián)網(wǎng)行業(yè)，利用自身積累的技術(shù)優(yōu)勢、行業(yè)經(jīng)驗、深度合作伙伴關(guān)系等，向廣大中小型企業(yè)、政府機構(gòu)等提供互聯(lián)網(wǎng)行業(yè)的解決方案，東風(fēng)網(wǎng)站推廣取得了明顯的社會效益與經(jīng)濟效益。目前，我們服務(wù)的客戶以成都為中心已經(jīng)輻射到東風(fēng)省份的部分城市，未來相信會繼續(xù)擴大服務(wù)區(qū)域并繼續(xù)獲得客戶的支持與信任！

PHP 多進程處理任務(wù)

pcntl 模塊（非 Unix 類系統(tǒng)不支持此模塊）

一個 PHP 多進程簡單例子大概是這個樣子：

// 5 個子進程處理任務(wù)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";// 業(yè)務(wù)處理        exit($i); // 一定要注意退出子進程，否則 pcntl_fork() 會被子進程再 fork，帶來處理上的影響。    }}// 等待子進程執(zhí)行結(jié)束while (pcntl_waitpid(0, $status) != -1) {$status = pcntl_wexitstatus($status);echo "Child $status completed\n";}

當(dāng)然實際應(yīng)用中我們不能夠這樣輸出代碼，不夠健壯，也不夠優(yōu)雅，我所以找了個基于 pcntl 封裝的擴展包來使用。

spatie/async - 基于 pcntl 封裝的擴展包

以下是我使用 spatie/async 來優(yōu)化一個多進程請求的例子

原代碼（耗時 20s 左右）- https://github.com/guanguans/...：

/** * @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 左右）- https://github.com/guanguans/...：

/** * @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;}

關(guān)于PHP中怎么利用多進程處理任務(wù)問題的解答就分享到這里了，希望以上內(nèi)容可以對大家有一定的幫助，如果你還有很多疑惑沒有解開，可以關(guān)注創(chuàng)新互聯(lián)行業(yè)資訊頻道了解更多相關(guān)知識。