并发

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

引言

有时你可能需要执行多个彼此之间没有依赖关系的耗时任务。在许多情况下，通过并发执行这些任务可以实现显著的性能提升。Laravel 的 Concurrency 门面提供了一个简单、便捷的 API 用于并发执行闭包。

工作原理

Laravel 通过序列化给定的闭包，并将它们分发到一个隐藏的 Artisan CLI 命令来实现并发，该命令会反序列化这些闭包并在其自身的 PHP 进程中调用它。 闭包被调用后，生成的值会被序列化回父进程。

Concurrency 门面支持三种驱动程序：process（默认），fork，和 sync。

fork 驱动相比默认的 process 驱动提供了改进的性能，但它只能在 PHP 的 CLI 上下文中使用，因为 PHP 不支持在 Web 请求期间进行分叉。在使用 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'),
]);