並行處理
簡介
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
(預設), fork
和 sync
。
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]);