简介 ​

WARNING

Laravel 的 php Concurrency facade 目前处于测试阶段,我们正在收集社区反馈。 有时候你可能需要执行若干不相互依赖的慢速任务。在许多情况下,通过并发执行这些任务可以显著提高性能。Laravel 的 php Concurrency facade 提供了一个简单、方便的 API 来并发地执行闭包。

工作原理 ​

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

php Concurrency facade 支持三种驱动:php process(默认)、php forkphp syncphp fork 驱动相比默认的 php process 驱动提供了更好的性能,但它只能在 PHP 的 CLI 环境中使用,因为 PHP 不支持在 Web 请求期间进行分叉。php sync 驱动主要在测试期间使用,当你想禁用所有并发并在父进程中按顺序执行给定闭包时非常有用。

运行并发任务 ​

要运行并发任务,可以调用 php Concurrency facade 的 php run 方法。php run 方法接受一个闭包数组,这些闭包将在子 PHP 进程中同时执行:

  1. use Illuminate\Support\Facades\Concurrency## ;
  2. use Illuminate\Support\Facades\DB;
  3. [$userCount, $orderCount] = Concurrency::run([
  4. fn () => DB::table('users')->count(),
  5. fn () => DB::table('orders')->count(),
  6. ]);

延迟并发任务 ​

如果你希望并发执行一组闭包,但对这些闭包返回的结果不感兴趣,可以考虑使用 php defer 方法。当调用 php defer 方法时,给定的闭包不会立即执行。相反,Laravel 会在 HTTP 响应发送给用户后并发执行这些闭包:

  1. use App\Services\Metrics## ;
  2. use Illuminate\Support\Facades\Concurrency;
  3. Concurrency::defer([
  4. fn () => Metrics::report('users'),
  5. fn () => Metrics::report('orders'),
  6. ]);