Lzh on GitHub

并发(Concurrency)

简介

有时您可能需要执行多个相互独立的慢速任务。在许多情况下,通过并发执行这些任务可以显着提高性能。Laravel 的 Concurrency Facade 提供了一个简单、方便的 API,用于并发执行闭包。

工作原理

Laravel 实现并发的方式是,它将给定的闭包序列化,并将其分派给一个隐藏的 Artisan CLI 命令,该命令会反序列化闭包并在其自己的 PHP 进程中调用它。闭包被调用后,结果值会被序列化回父进程。

Concurrency Facade 支持三种驱动程序:process(默认)、forksync

  • fork 驱动程序与默认的 process 驱动程序相比,性能有所提高,但它只能在 PHP 的 CLI 环境中使用,因为 PHP 不支持在 Web 请求期间进行分叉。在使用 fork 驱动程序之前,您需要安装 spatie/fork 包:
    composer require spatie/fork
    
  • sync 驱动程序主要用于测试,当您想禁用所有并发并简单地在父进程中按顺序执行给定的闭包时。

运行并发任务

要运行并发任务,您可以调用 Concurrency Facade 的 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'),
]);