summaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorVinay Sajip <vinay_sajip@yahoo.co.uk>2019-07-22 11:14:50 (GMT)
committerGitHub <noreply@github.com>2019-07-22 11:14:50 (GMT)
commitd309352c6fd93a51f2b3011ca8c2125d3a5d394b (patch)
tree6528a6d3ecf2ccf5bcaa3ba5ecffb9edac57724b
parent7397cda99795a4a8d96193d710105e77a07b7411 (diff)
downloadcpython-d309352c6fd93a51f2b3011ca8c2125d3a5d394b.zip
cpython-d309352c6fd93a51f2b3011ca8c2125d3a5d394b.tar.gz
cpython-d309352c6fd93a51f2b3011ca8c2125d3a5d394b.tar.bz2
Update logging cookbook to show multiple worker processes using the concurrent.futures module. (#14905)
-rw-r--r--Doc/howto/logging-cookbook.rst35
1 files changed, 35 insertions, 0 deletions
diff --git a/Doc/howto/logging-cookbook.rst b/Doc/howto/logging-cookbook.rst
index 87ac79e..e623081 100644
--- a/Doc/howto/logging-cookbook.rst
+++ b/Doc/howto/logging-cookbook.rst
@@ -948,6 +948,41 @@ This variant shows how you can e.g. apply configuration for particular loggers
machinery in the main process (even though the logging events are generated in
the worker processes) to direct the messages to the appropriate destinations.
+Using concurrent.futures.ProcessPoolExecutor
+^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
+
+If you want to use :class:`concurrent.futures.ProcessPoolExecutor` to start
+your worker processes, you need to create the queue slightly differently.
+Instead of
+
+.. code-block:: python
+
+ queue = multiprocessing.Queue(-1)
+
+you should use
+
+.. code-block:: python
+
+ queue = multiprocessing.Manager().Queue(-1) # also works with the examples above
+
+and you can then replace the worker creation from this::
+
+ workers = []
+ for i in range(10):
+ worker = multiprocessing.Process(target=worker_process,
+ args=(queue, worker_configurer))
+ workers.append(worker)
+ worker.start()
+ for w in workers:
+ w.join()
+
+to this (remembering to first import :mod:`concurrent.futures`)::
+
+ with concurrent.futures.ProcessPoolExecutor(max_workers=10) as executor:
+ for i in range(10):
+ executor.submit(worker_process, queue, worker_configurer)
+
+
Using file rotation
-------------------