跳到內容

並行處理

簡介

Laravel 的 Concurrency facade 目前處於 beta 階段,我們正在收集社群回饋。

有時您可能需要執行幾個互不相依的慢速任務。在許多情況下,透過並行執行任務可以實現顯著的效能提升。Laravel 的 Concurrency facade 提供了一個簡單、方便的 API 來並行執行 closures。

並行處理相容性

如果您從 Laravel 10.x 應用程式升級到 Laravel 11.x,您可能需要在應用程式的 config/app.php 設定檔中將 ConcurrencyServiceProvider 添加到 providers 陣列中

1'providers' => ServiceProvider::defaultProviders()->merge([
2 /*
3 * Package Service Providers...
4 */
5 Illuminate\Concurrency\ConcurrencyServiceProvider::class,
6 
7 /*
8 * Application Service Providers...
9 */
10 App\Providers\AppServiceProvider::class,
11 App\Providers\AuthServiceProvider::class,
12 // App\Providers\BroadcastServiceProvider::class,
13 App\Providers\EventServiceProvider::class,
14 App\Providers\RouteServiceProvider::class,
15])->toArray(),

運作方式

Laravel 透過序列化給定的 closures 並將其分派到一個隱藏的 Artisan CLI 命令來實現並行處理,該命令會反序列化 closures 並在其自身的 PHP 進程中調用它。在 closure 被調用後,結果值會被序列化回父進程。

Concurrency facade 支援三個驅動程式:process (預設), forksync

fork 驅動程式相比預設的 process 驅動程式提供了更佳的效能,但它僅能用於 PHP 的 CLI 環境中,因為 PHP 不支援在 Web 請求期間進行 fork 操作。在使用 fork 驅動程式之前,您需要安裝 spatie/fork 套件

1composer require spatie/fork

sync 驅動程式主要在測試期間很有用,當您想要禁用所有並行處理並僅在父進程中依序執行給定的 closures 時。

執行並行任務

要執行並行任務,您可以調用 Concurrency facade 的 run 方法。run 方法接受一個 closures 陣列,這些 closures 應在子 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

延遲並行任務

如果您想並行執行 closures 陣列,但對這些 closures 返回的結果不感興趣,您應該考慮使用 defer 方法。當調用 defer 方法時,給定的 closures 不會立即執行。相反地,Laravel 會在 HTTP 回應已發送給使用者後並行執行這些 closures

1use App\Services\Metrics;
2use Illuminate\Support\Facades\Concurrency;
3 
4Concurrency::defer([
5 fn () => Metrics::report('users'),
6 fn () => Metrics::report('orders'),
7]);