并发

简介
运行并发任务
延迟并发任务

简介

在收集社区反馈期间，Laravel 的 Concurrency 外观模式目前处于 Beta 测试阶段。

有时你可能需要执行多个互不依赖的缓慢任务。在许多情况下，通过并发执行任务可以实现显著的性能改进。Laravel 的 Concurrency 外观模式为并发执行闭包提供了一个简单方便的 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 外观模式支持三个驱动程序：process（默认）、fork 和 sync。

与默认的 process 驱动程序相比，fork 驱动程序提供了更高的性能，但它只能在 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 命令发布 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'),
]);