跳转至内容

并发

简介

有时你可能需要执行多个互不依赖的耗时任务。在许多情况下,通过并发执行这些任务可以显著提升性能。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]);