併發
簡介
有時你可能需要執行多個互不依賴的耗時任務。在許多情況下,透過併發執行這些任務可以顯著提升效能。Laravel 的 Concurrency 門面(facade)提供了一個簡單、便捷的 API 來併發執行閉包。
工作原理
Laravel 透過序列化給定的閉包並將它們分發到一個隱藏的 Artisan CLI 命令來實現併發。該命令會反序列化這些閉包,並在其獨立的 PHP 程序中呼叫它們。閉包執行完成後,返回的結果會被序列化並傳回父程序。
Concurrency 門面支援三種驅動:process(預設)、fork 和 sync。
與預設的 process 驅動相比,fork 驅動提供了更好的效能,但它只能在 PHP 的 CLI 環境中使用,因為 PHP 不支援在 Web 請求期間進行程序派生(forking)。在使用 fork 驅動之前,你需要安裝 spatie/fork 擴充套件包。
1composer require spatie/fork
sync 驅動主要用於測試場景,當你希望停用所有併發,並僅在父程序中按順序執行給定的閉包時非常有用。
執行併發任務
要執行併發任務,你可以呼叫 Concurrency 門面的 run 方法。run 方法接收一個閉包陣列,這些閉包將在子 PHP 程序中同時執行。
1use Illuminate\Support\Facades\Concurrency;2use Illuminate\Support\Facades\DB;3 4[$userCount, $orderCount] = Concurrency::run([5 fn () => DB::table('users')->count(),6 fn () => DB::table('orders')->count(),7]);
要使用特定的驅動,你可以使用 driver 方法。
1$results = Concurrency::driver('fork')->run(...);
或者,若要更改預設的併發驅動,你應該透過 config:publish Artisan 命令釋出 concurrency 配置檔案,並更新檔案中的 default 選項。
1php artisan config:publish concurrency
延遲執行併發任務
如果你希望併發執行一組閉包,但並不關心這些閉包返回的結果,你應該考慮使用 defer 方法。當呼叫 defer 方法時,給定的閉包不會立即執行。相反,Laravel 將在 HTTP 響應傳送給使用者之後併發執行這些閉包。
1use App\Services\Metrics;2use Illuminate\Support\Facades\Concurrency;3 4Concurrency::defer([5 fn () => Metrics::report('users'),6 fn () => Metrics::report('orders'),7]);