如何使用spatie/async库来写异步的PHP代码-创新互联

如何使用spatie/async库来写异步的PHP代码？这个问题可能是我们日常学习或工作经常见到的。希望通过这个问题能让你收获颇深。下面是小编给大家带来的参考内容，让我们一起来看看吧！

创新互联建站专业为企业提供共和网站建设、共和做网站、共和网站设计、共和网站制作等企业网站建设、网页设计与制作、共和企业网站模板建站服务，十年共和做网站经验，不只是建网站，更提供有价值的思路和整体网络服务。

对于大多数用 PHP 编写的程序，它的目的是执行由多个任务组成的简单进程，其中任务必须按顺序执行，如数据处理。我们总是不得不忍受同步编程的停止和等待。代码执行的同步风格被称为阻塞，这意味着任务将一个接一个地执行。那么，如果我们想要运行任务而不让它们相互阻塞，这意味着我们需要一个非阻塞进程，那该怎么办呢？这种方法需要在 PHP 中应用异步编程方法，这里的任务将在不相互依赖的情况下执行。

在 PHP 中实现非阻塞执行的一种常见方法是实现队列处理。任务被持久保存到 MySQL、Redis、Amazon SQS 等传输系统中，该传输系统由后台 worker 检索并相应地执行，从而不会阻塞创建任务的主进程。Laravel 应用程序提供了一种队列机制，允许将任务(在本例中称为作业)推迟到稍后的时间进行处理。

另一种方法是并行运行所有定义的任务。我们从这种方法中知道的是，特定的任务完成后，它可以立即将控制权交还主进程，并承诺执行代码并在稍后通知我们结果(例如回调)。人们可能很少看到并行处理方法的用例；示例用例可能是执行图像处理并向某些外部服务发出 GET 请求。

让我们通过一个非常简单的用例来看看 PHP 中同步和异步(并行)流程之间的区别。

同步代码

foreach (range(1, 5) as $i) {
    $output = $i * 2;
    echo $output . "\n";
}

异步代码

use Spatie\Async\Pool;

$pool = Pool::create();

foreach (range(1, 5) as $i) {
    $pool[] = async(function () use ($i) {
       $output = $i * 2;
       return $output;
    })->then(function (int $output) {
       echo $output . "\n";
    });
}
await($pool);

当我们执行第一个代码时，我们将按以下顺序获得输出值：

重试执行，我们将获得与上面相同的顺序的输出。因此，每个乘法运算都要在下一个乘法运算之前等待执行。接下来，运行第二个代码块，让我们看看我们得到了什么。

第二次重试执行：

一个过程产生两个不同的结果。这正是我们使用异步方法所得到的结果。我们的小任务可以以一种互不阻塞的方式执行。每个乘法任务都是独立执行的，有些执行得比其他任务快，因此输出结果混乱无序。另外，请注意我们的异步函数作为 then 方法附加，该方法负责取回控制权，并且它接受回调函数作为其参数，该回调函数现在可以对接收到的输出执行额外的操作。

Spatie 的工作人员开发了这个很好的spacee/async包，它有助于并行执行任务。你可以通过 Composer 安装该包：

composer require spatie/async

该包提供了一种巧妙的方式来与创建的任务进行交互，这些任务将被并行执行。任务的事件监听器描述如下：

当任务完成时再执行一次操作，是因为回调可以通过它的then方法来实现。
当一个特定的任务使用catch方法抛出异常时，错误处理更容易控制。
当一个任务没有完成其操作时，timeout方法允许人们处理这样的场景。

事件监听器与如下所示的任务挂钩：

$pool
    ->add(function () {
        // 要在并行进程中执行的任务
    })
    ->then(function ($output) {
        // 如果成功，进程或者你传递到队列的回调函数会返回`$output`。
    })
    ->catch(function ($exception) {
        // 当进程内抛出异常时，它会被捕获并传递到这里。
    })
    ->timeout(function () {
        // 哦，不！ 一个过程花了太长时间才完成。 让我们做点什么吧
    })
;

感谢各位的阅读！看完上述内容，你们对如何使用spatie/async库来写异步的PHP代码大概了解了吗？希望文章内容对大家有所帮助。如果想了解更多相关文章内容，欢迎关注创新互联行业资讯频道。

分享文章：如何使用spatie/async库来写异步的PHP代码-创新互联
标题来源：https://www.cdcxhl.com/article34/dsphse.html

成都网站建设公司_创新互联，为您提供外贸建站、定制开发、企业网站制作、建站公司、网站导航、电子商务

声明：本网站发布的内容（图片、视频和文字）以用户投稿、用户转载内容为主，如果涉及侵权请尽快告知，我们将会在第一时间删除。文章观点不代表本网站立场，如需处理请联系客服。电话：028-86922220；邮箱：631063699@qq.com。内容未经允许不得转载，或转载时需注明来源：创新互联

猜你还喜欢下面的内容