并发

引言

Laravel 的 Concurrency 门面目前处于测试阶段，我们正在收集社区反馈。

有时，您可能需要同时执行多个不相互依赖的慢任务。在许多情况下，通过并发执行任务，可以显著提高性能。Laravel 的 Concurrency 门面提供了一个简单、便捷的 API，用于并发执行闭包。

并发兼容性

如果您是从 Laravel 10.x 升级到 Laravel 11.x，可能需要将 ConcurrencyServiceProvider 添加到应用程序的 config/app.php 配置文件中的 providers 数组：

'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 门面支持三种驱动程序：process（默认）、fork 和 sync。

fork 驱动程序 提供了比默认的 process 驱动程序更好的性能，但仅限于 PHP 的 CLI 环境，因为 PHP 在 Web 请求期间不支持 fork 操作。在使用 fork 驱动程序之前，您需要安装 spatie/fork 包：

composer require spatie/fork

sync 驱动程序 主要用于测试期间，当您希望禁用所有并发并在父进程中按顺序执行给定的闭包时使用。

运行并发任务

要运行并发任务，您可以调用 Concurrency 门面的 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 命令发布并发配置文件，并在文件中更新 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'),
]);