arko/queue-manager

可调用队列管理器

dev-master 2015-06-26 21:35 UTC

This package is not auto-updated.

Last update: 2024-09-28 18:15:56 UTC


README

安装

使用composer安装

composer.phar require arko/queue-manager "dev-master"

如何使用

一般来说,这个组件被设计成单例模式使用。假设QueueManager(或任何实现了QueueManagerInterface接口的类)实例只会被创建一次,并在之后通过像Symfony或Pimple这样的服务容器进行检索。然而,具体如何使用它取决于您。

您可以像这样创建队列管理器的实例

$queueManager = new Arko\QueueManager\QueueManager();

从现在起,您可以使用它向命名队列添加不同的操作

$queueManager->add(function() {
    // Do something here
}, 'queue_name');

// ...

$queueManager->add(function() {
    // Do something else, maybe somewhere else.
}, 'queue_name');

在队列管理器的添加方法中,您可以提供任何PHP可调用对象。

稍后您将能够这样处理队列

$queueManager->process('queue_name');

队列被处理后,它将被清除。一般来说,它会在处理队列之前被清除。所以,嵌套队列应该可以正常工作。