跳至内容

并发

介绍

有时您可能需要执行多个彼此不依赖的慢速任务。很多情况下，并发执行这些任务可以显著提升性能。Laravel 的ConcurrencyFacade 提供了一套简单便捷的 API 来并发执行闭包。

工作原理

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

外观Concurrency支持三种驱动程序：process（默认）、fork和sync。

fork与默认驱动程序相比，此驱动程序的性能有所提升process，但只能在 PHP 的 CLI 环境中使用，因为 PHP 不支持在 Web 请求期间进行分叉。使用此fork驱动程序之前，您需要安装以下spatie/fork软件包：

1composer require spatie/fork

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

运行并发任务

要运行并发任务，你可以调用ConcurrencyFacade 的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(...);

或者，要更改默认并发驱动程序，您应该concurrency通过config:publishArtisan 命令发布配置文件并更新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]);