diff --git a/README.md b/README.md index c649f9b..78f2a08 100644 --- a/README.md +++ b/README.md @@ -249,7 +249,7 @@ def run_with_multiprocessing(): for i in range(n_processes): queue.put(None) - queue.join() + queue.join() flush() diff --git a/examples/example_04_multiprocessing.py b/examples/example_04_multiprocessing.py index 5e24b3a..0aa6ae6 100755 --- a/examples/example_04_multiprocessing.py +++ b/examples/example_04_multiprocessing.py @@ -44,7 +44,7 @@ def worker(reporter, task, queue): for i in range(n_processes): queue.put(None) - queue.join() + queue.join() flush()