This document is for Kombu's development version, which can be significantly different from previous releases. Get the stable docs here: 4.5.
Resource Management - kombu.resource
¶
Generic resource pool implementation.
-
class
kombu.resource.
Resource
(limit=None, preload=None, close_after_fork=None)[source]¶ Pool of resources.
-
exception
LimitExceeded
¶ Limit exceeded.
-
acquire
(block=False, timeout=None)[source]¶ Acquire resource.
- Parameters
- Raises
LimitExceeded – if block is false and the limit has been exceeded.
-
close_after_fork
= False¶
-
force_close_all
()[source]¶ Close and remove all resources in the pool (also those in use).
Used to close resources from parent processes after fork (e.g. sockets/connections).
-
property
limit
¶
-
exception