mirror of
https://github.com/ets-labs/python-dependency-injector.git
synced 2024-11-22 09:36:48 +03:00
7d160cb4a5
* Update main example * Updating wiring module * Update wiring test case name * Implement string imports for wiring * Update example * Refactor implementation * Update front example * Fix a typo in README * Update wiring docs * Update single container example * Update multiple containers example * Update quotes in multiple containers example * Update quotes in single container example * Update decoupled-packages example * Update single and multiple containers example * Update quotes * Update fastapi+redis example * Update resource docs * Update quotes in CLI tutorial * Update CLI application (movie lister) tutorial * Update monitoring daemon example * Update python version in asyncio daemon example * Update asyncio daemon tutorial * Update quotes in wiring docs * Update wiring docs
42 lines
934 B
Python
42 lines
934 B
Python
"""`Resource` provider example."""
|
|
|
|
import sys
|
|
import logging
|
|
from concurrent.futures import ThreadPoolExecutor
|
|
|
|
from dependency_injector import containers, providers
|
|
|
|
|
|
def init_thread_pool(max_workers: int):
|
|
thread_pool = ThreadPoolExecutor(max_workers=max_workers)
|
|
yield thread_pool
|
|
thread_pool.shutdown(wait=True)
|
|
|
|
|
|
class Container(containers.DeclarativeContainer):
|
|
|
|
config = providers.Configuration()
|
|
|
|
thread_pool = providers.Resource(
|
|
init_thread_pool,
|
|
max_workers=config.max_workers,
|
|
)
|
|
|
|
logging = providers.Resource(
|
|
logging.basicConfig,
|
|
level=logging.INFO,
|
|
stream=sys.stdout,
|
|
)
|
|
|
|
|
|
if __name__ == "__main__":
|
|
container = Container(config={"max_workers": 4})
|
|
|
|
container.init_resources()
|
|
|
|
logging.info("Resources are initialized")
|
|
thread_pool = container.thread_pool()
|
|
thread_pool.map(print, range(10))
|
|
|
|
container.shutdown_resources()
|