如何使用spatie/async庫(kù)來(lái)寫(xiě)異步的PHP代碼？這個(gè)問(wèn)題可能是我們?nèi)粘W(xué)習(xí)或工作經(jīng)常見(jiàn)到的。希望通過(guò)這個(gè)問(wèn)題能讓你收獲頗深。下面是小編給大家?guī)?lái)的參考內(nèi)容，讓我們一起來(lái)看看吧！
對(duì)于大多數(shù)用 PHP 編寫(xiě)的程序，它的目的是執(zhí)行由多個(gè)任務(wù)組成的簡(jiǎn)單進(jìn)程，其中任務(wù)必須按順序執(zhí)行，如數(shù)據(jù)處理。我們總是不得不忍受同步編程的停止和等待。代碼執(zhí)行的同步風(fēng)格被稱(chēng)為阻塞，這意味著任務(wù)將一個(gè)接一個(gè)地執(zhí)行。那么，如果我們想要運(yùn)行任務(wù)而不讓它們相互阻塞，這意味著我們需要一個(gè)非阻塞進(jìn)程，那該怎么辦呢？這種方法需要在 PHP 中應(yīng)用異步編程方法，這里的任務(wù)將在不相互依賴的情況下執(zhí)行。
在 PHP 中實(shí)現(xiàn)非阻塞執(zhí)行的一種常見(jiàn)方法是實(shí)現(xiàn)隊(duì)列處理。任務(wù)被持久保存到 MySQL、Redis、Amazon SQS 等傳輸系統(tǒng)中，該傳輸系統(tǒng)由后臺(tái) worker 檢索并相應(yīng)地執(zhí)行，從而不會(huì)阻塞創(chuàng)建任務(wù)的主進(jìn)程。Laravel 應(yīng)用程序提供了一種隊(duì)列機(jī)制，允許將任務(wù)(在本例中稱(chēng)為作業(yè))推遲到稍后的時(shí)間進(jìn)行處理。
另一種方法是并行運(yùn)行所有定義的任務(wù)。我們從這種方法中知道的是，特定的任務(wù)完成后，它可以立即將控制權(quán)交還主進(jìn)程，并承諾執(zhí)行代碼并在稍后通知我們結(jié)果(例如回調(diào))。人們可能很少看到并行處理方法的用例；示例用例可能是執(zhí)行圖像處理并向某些外部服務(wù)發(fā)出 GET 請(qǐng)求。
讓我們通過(guò)一個(gè)非常簡(jiǎn)單的用例來(lái)看看 PHP 中同步和異步(并行)流程之間的區(qū)別。
同步代碼
重慶分公司
重慶分公司
foreach (range(1, 5) as $i) {
$output = $i * 2;
echo $output . "\n";
}異步代碼
use Spatie\Async\Pool;
$pool = Pool::create();
foreach (range(1, 5) as $i) {
$pool[] = async(function () use ($i) {
$output = $i * 2;
return $output;
})->then(function (int $output) {
echo $output . "\n";
});
}
await($pool);當(dāng)我們執(zhí)行第一個(gè)代碼時(shí)，我們將按以下順序獲得輸出值：
2 4 6 8 10
重試執(zhí)行，我們將獲得與上面相同的順序的輸出。因此，每個(gè)乘法運(yùn)算都要在下一個(gè)乘法運(yùn)算之前等待執(zhí)行。接下來(lái)，運(yùn)行第二個(gè)代碼塊，讓我們看看我們得到了什么。
6 10 2 8 4
第二次重試執(zhí)行：
2 6 4 10 8
一個(gè)過(guò)程產(chǎn)生兩個(gè)不同的結(jié)果。這正是我們使用異步方法所得到的結(jié)果。我們的小任務(wù)可以以一種互不阻塞的方式執(zhí)行。每個(gè)乘法任務(wù)都是獨(dú)立執(zhí)行的，有些執(zhí)行得比其他任務(wù)快，因此輸出結(jié)果混亂無(wú)序。另外，請(qǐng)注意我們的異步函數(shù)作為 then 方法附加，該方法負(fù)責(zé)取回控制權(quán)，并且它接受回調(diào)函數(shù)作為其參數(shù)，該回調(diào)函數(shù)現(xiàn)在可以對(duì)接收到的輸出執(zhí)行額外的操作。
Spatie 的工作人員開(kāi)發(fā)了這個(gè)很好的spacee/async包，它有助于并行執(zhí)行任務(wù)。你可以通過(guò) Composer 安裝該包：
composer require spatie/async
該包提供了一種巧妙的方式來(lái)與創(chuàng)建的任務(wù)進(jìn)行交互，這些任務(wù)將被并行執(zhí)行。任務(wù)的事件監(jiān)聽(tīng)器描述如下：
then方法來(lái)實(shí)現(xiàn)。catch方法拋出異常時(shí)，錯(cuò)誤處理更容易控制。timeout方法允許人們處理這樣的場(chǎng)景。事件監(jiān)聽(tīng)器與如下所示的任務(wù)掛鉤：
$pool
->add(function () {
// 要在并行進(jìn)程中執(zhí)行的任務(wù)
})
->then(function ($output) {
// 如果成功，進(jìn)程或者你傳遞到隊(duì)列的回調(diào)函數(shù)會(huì)返回`$output`。
})
->catch(function ($exception) {
// 當(dāng)進(jìn)程內(nèi)拋出異常時(shí)，它會(huì)被捕獲并傳遞到這里。
})
->timeout(function () {
// 哦，不！ 一個(gè)過(guò)程花了太長(zhǎng)時(shí)間才完成。 讓我們做點(diǎn)什么吧
})
;感謝各位的閱讀！看完上述內(nèi)容，你們對(duì)如何使用spatie/async庫(kù)來(lái)寫(xiě)異步的PHP代碼大概了解了嗎？希望文章內(nèi)容對(duì)大家有所幫助。如果想了解更多相關(guān)文章內(nèi)容，歡迎關(guān)注創(chuàng)新互聯(lián)行業(yè)資訊頻道。
