跳轉至內容

併發

簡介

有時你可能需要執行多個互不依賴的耗時任務。在許多情況下,透過併發執行這些任務可以顯著提升效能。Laravel 的 Concurrency 門面(facade)提供了一個簡單、便捷的 API 來併發執行閉包。

工作原理

Laravel 透過序列化給定的閉包並將它們分發到一個隱藏的 Artisan CLI 命令來實現併發。該命令會反序列化這些閉包,並在其獨立的 PHP 程序中呼叫它們。閉包執行完成後,返回的結果會被序列化並傳回父程序。

Concurrency 門面支援三種驅動:process(預設)、forksync

與預設的 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]);