简介

有时你可能需要执行若干互不依赖的耗时任务。在很多情况下，通过并发执行这些任务可显著提升性能。Laravel 的 Concurrency 门面提供了一套简洁便捷的 API，用于并发执行闭包。

工作原理

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

具名结果

如果你希望通过名称而不是位置来访问并发任务的结果，可以提供一个以闭包为值的关联数组。每个结果会使用与其对应闭包相同的键返回：

use Illuminate\Support\Facades\Concurrency;
use Illuminate\Support\Facades\DB;

$results = Concurrency::run([
    'users' => fn () => DB::table('users')->count(),
    'orders' => fn () => DB::table('orders')->count(),
]);

$userCount = $results['users'];
$orderCount = $results['orders'];

任务超时

在使用 process 驱动（默认）时，你可以通过向 run 方法提供超时参数，指定并发任务在被终止前允许运行的最大秒数：

use Illuminate\Support\Facades\Concurrency;
use Illuminate\Support\Facades\DB;

[$userCount, $orderCount] = Concurrency::run([
    fn () => DB::table('users')->count(),
    fn () => DB::table('orders')->count(),
], timeout: 30);

如果你更倾向于以更具表达力的方式定义超时，也可以提供一个 CarbonInterval 实例：

use Illuminate\Support\Facades\Concurrency;

use function Illuminate\Support\seconds;

Concurrency::run([...], timeout: seconds(30));

延迟执行并发任务

如果你希望并发执行一组闭包，但并不关心这些闭包返回的结果，建议使用 defer 方法。调用 defer 方法时，给定的闭包不会立即执行。相反，Laravel 会在将 HTTP 响应发送给用户后，再并发执行这些闭包：

use App\Services\Metrics;
use Illuminate\Support\Facades\Concurrency;

Concurrency::defer([
    fn () => Metrics::report('users'),
    fn () => Metrics::report('orders'),
]);