并发

未匹配的标注
本文档最新版为 12.x,旧版本可能放弃维护,推荐阅读最新版!

并发

介绍

有时,你可能需要执行多个互不依赖的耗时任务。在许多情况下,并发执行这些任务可以显著提高性能。Laravel 的 Concurrency 门面提供了一个简单、便捷的 API,用于并发执行闭包。

工作原理

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

Concurrency 门面支持三种驱动:process(默认)、forksync

与默认的 process 驱动相比,fork 驱动性能更好,但它只能在 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

命名结果

如果希望按名称而不是按位置访问并发任务的结果,可以提供一个由闭包组成的关联数组。每个结果都将使用其对应闭包的相同键名返回:

use Illuminate\Support\Facades\Concurrency;
use Illuminate\Support\Facades\DB;

$results = Concurrency::run([
    'users' => fn () => DB::table('users')->count(),
    'orders' => fn () => DB::table('orders')->count(),
]);

$userCount = $results['users'];
$orderCount = $results['orders'];

任务超时

使用 process 驱动(默认驱动)时,可以向 run 方法传入超时时间,指定并发任务在被终止前允许运行的最大秒数:

use Illuminate\Support\Facades\Concurrency;
use Illuminate\Support\Facades\DB;

[$userCount, $orderCount] = Concurrency::run([
    fn () => DB::table('users')->count(),
    fn () => DB::table('orders')->count(),
], timeout: 30);

如果希望以更具表达力的方式定义超时时间,也可以传入 CarbonInterval 实例:

use Illuminate\Support\Facades\Concurrency;

use function Illuminate\Support\seconds;

Concurrency::run([...], timeout: seconds(30));

延迟并发任务

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

use App\Services\Metrics;
use Illuminate\Support\Facades\Concurrency;

Concurrency::defer([
    fn () => Metrics::report('users'),
    fn () => Metrics::report('orders'),
]);

本文章首发在 LearnKu.com 网站上。

本译文仅用于学习和交流目的,转载请务必注明文章译者、出处、和本文链接
我们的翻译工作遵照 CC 协议,如果我们的工作有侵犯到您的权益,请及时联系我们。

原文地址:https://learnku.com/docs/laravel/13.x/co...

译文地址:https://learnku.com/docs/laravel/13.x/co...

上一篇 下一篇
《L01 基础入门》
我们将带你从零开发一个项目并部署到线上,本课程教授 Web 开发中专业、实用的技能,如 Git 工作流、Laravel Mix 前端工作流等。
《L03 构架 API 服务器》
你将学到如 RESTFul 设计风格、PostMan 的使用、OAuth 流程,JWT 概念及使用 和 API 开发相关的进阶知识。
贡献者:1
讨论数量: 0
发起讨论 只看当前版本


暂无话题~