This document is for Kombu's development version, which can be significantly different from previous releases. Get the stable docs here: 5.0.

资源管理- kombu.resource

通用资源池实施。

class kombu.resource.LifoQueue(maxsize=0)

队列的后进先出版本。

class kombu.resource.Resource(limit=None, preload=None, close_after_fork=None)

资源池。

exception LimitExceeded

已超过限制。

acquire(block=False, timeout=None)

获取资源。

论点：

BLOCK(Bool)：如果超过限制，

然后阻止，直到有可用的项目。

超时(浮点数)：等待超时

如果 block 是真的。缺省值为 None (永远)。

提升LimitExceed:

IF BLOCK为FALSE且已超过限制。：

close_after_fork = False

close_resource(resource)

collect_resource(resource)

force_close_all()

关闭并删除池中的所有资源(包括正在使用的资源)。

用于在分叉之后关闭父进程的资源(例如套接字/连接)。

property limit

prepare(resource)

release(resource)

release_resource(resource)

replace(resource)

用新实例替换现有资源。

这可以在资源有缺陷的情况下使用。

resize(limit, force=False, ignore_errors=False, reset=False)

setup()