並行處理

簡介
執行並行任務
延遲並行任務

簡介

Laravel 的 Concurrency facade 目前處於 Beta 測試階段，我們正在收集社群回饋。

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

並行處理相容性

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

'providers' => ServiceProvider::defaultProviders()->merge([
    /*
     * Package Service Providers...
     */
    Illuminate\Concurrency\ConcurrencyServiceProvider::class, 
 
    /*
     * Application Service Providers...
     */
    App\Providers\AppServiceProvider::class,
    App\Providers\AuthServiceProvider::class,
    // App\Providers\BroadcastServiceProvider::class,
    App\Providers\EventServiceProvider::class,
    App\Providers\RouteServiceProvider::class,
])->toArray(),

運作方式

Laravel 透過序列化給定的閉包，並將其分派到一個隱藏的 Artisan CLI 命令來實現並行處理，該命令會反序列化閉包並在其自己的 PHP 進程中呼叫它。在呼叫閉包後，結果值會被序列化回父進程。

Concurrency facade 支援三個驅動程式：process（預設）、fork 和 sync。

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

composer require spatie/fork

sync 驅動程式主要在測試期間使用，當您想要停用所有並行處理並僅在父進程中按順序執行給定的閉包時。

執行並行任務

要執行並行任務，您可以呼叫 Concurrency facade 的 run 方法。run 方法接受一個閉包陣列，這些閉包應該在子 PHP 進程中同時執行。

use Illuminate\Support\Facades\Concurrency;
use Illuminate\Support\Facades\DB;
 
[$userCount, $orderCount] = Concurrency::run([
    fn () => DB::table('users')->count(),
    fn () => DB::table('orders')->count(),
]);

要使用特定的驅動程式，您可以使用 driver 方法。

$results = Concurrency::driver('fork')->run(...);

或者，要變更預設的並行處理驅動程式，您應該透過 config:publish Artisan 命令發布 concurrency 設定檔，並更新檔案中的 default 選項。

php artisan config:publish concurrency

延遲並行任務

如果您想要並行執行閉包陣列，但不關心這些閉包傳回的結果，您應該考慮使用 defer 方法。當呼叫 defer 方法時，給定的閉包不會立即執行。相反地，Laravel 會在 HTTP 響應傳送給使用者後並行執行這些閉包。

use App\Services\Metrics;
use Illuminate\Support\Facades\Concurrency;
 
Concurrency::defer([
    fn () => Metrics::report('users'),
    fn () => Metrics::report('orders'),
]);