From 2b53ccdfe7a326251d6774df692aa7be19f19ad0 Mon Sep 17 00:00:00 2001 From: Roman Mogylatov Date: Fri, 23 Oct 2020 13:47:47 -0400 Subject: [PATCH] Move resources example --- examples/providers/{resource => }/resource.py | 15 ++++++++++++--- 1 file changed, 12 insertions(+), 3 deletions(-) rename examples/providers/{resource => }/resource.py (62%) diff --git a/examples/providers/resource/resource.py b/examples/providers/resource.py similarity index 62% rename from examples/providers/resource/resource.py rename to examples/providers/resource.py index c2b16c68..46744554 100644 --- a/examples/providers/resource/resource.py +++ b/examples/providers/resource.py @@ -1,12 +1,14 @@ """`Resource` provider example.""" -import concurrent.futures +import sys +import logging +from concurrent.futures import ThreadPoolExecutor from dependency_injector import containers, providers def init_threat_pool(max_workers: int): - thread_pool = concurrent.futures.ThreadPoolExecutor(max_workers=max_workers) + thread_pool = ThreadPoolExecutor(max_workers=max_workers) yield thread_pool thread_pool.shutdown(wait=True) @@ -20,13 +22,20 @@ class Container(containers.DeclarativeContainer): 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() - assert list(thread_pool.map(str, range(3))) == ['0', '1', '2'] + thread_pool.map(print, range(10)) container.shutdown_resources()