Take advantage of the integrated termination process.

We now use the termination process f pyfunceble-process-manager instead
of trying control it ourselves.

Author: funilrys

PyFunceble/cli/system/launcher.py

@@ -1090,10 +1090,16 @@ def stop_and_wait_for_all_manager(self) -> "SystemLauncher":
         Sends our stop signal and wait until all managers are finished.
         """
 
-        # The idea out here is to propate the stop signal.
-        # Meaning that the tester will share it's stop signal to all
-        # subsequencial queues after all submitted tasks are done.
-        self.tester_process_manager.push_stop_signal(source_worker="main")
+        # We start the termination process of the tester.
+        #
+        # Please note that we do not explicitly wait for the tester to terminate
+        # through the `wait` method. The reason is that the `terminate` method
+        # will wait for the tester to finish before terminating itself.
+        #
+        # Please also note that any process depending on the tester will be
+        # terminated after the tester is done because we are setting the
+        # `spread_stop_signal` # attribute to `True` (cf: see __init__ method).
+        self.tester_process_manager.terminate()
 
         if self.miner_process_manager:
             self.miner_process_manager.wait()
@@ -1105,8 +1111,7 @@ def stop_and_wait_for_all_manager(self) -> "SystemLauncher":
             # From here, we are sure that every test and files are produced.
             # We now format the generated file(s).
             self.dir_files_sorter_process_manager.start()
-            self.dir_files_sorter_process_manager.push_stop_signal()
-            self.dir_files_sorter_process_manager.wait()
+            self.dir_files_sorter_process_manager.terminate()
         except AssertionError:
             # Example: Already started previously.
             pass

PyFunceble/storage.py

@@ -60,7 +60,7 @@
 from PyFunceble.storage_facility import get_config_directory
 
 PROJECT_NAME: str = "PyFunceble"
-PROJECT_VERSION: str = "4.3.0a17.dev (Blue Duckling: Tulip)"
+PROJECT_VERSION: str = "4.3.0a18.dev (Blue Duckling: Tulip)"
 
 DISTRIBUTED_CONFIGURATION_FILENAME: str = ".PyFunceble_production.yaml"
 

docs/develop/examples/file-generation.md

@@ -101,7 +101,7 @@ for domain in DOMAINS:
 producer_proc.push_stop_signal()
 
 # Now we wait until it's done.
-producer_proc.wait()
+producer_proc.terminate()
 
 # From here all files were generated we can do whatever we want with them.
 ```

examples/api_usage/file_generation.py

@@ -90,13 +90,8 @@
             (communication_dataset, test_result)
         )
 
-    # We are now done, it's time to send the stop signal.
-    # The stop signal will inform thhe producer thread that it needs to stop
-    # listening to new order (from the time it reads the stop signal).
-    producer_process_manager.push_stop_signal(source_worker="main")
-
-    # Now we wait until it's done.
-    producer_process_manager.wait()
+    # We are now done, it's time to wait and shutdown.
+    producer_process_manager.terminate()
 
     # From here all files were generated we can do whatever we want with them.
 

version.yaml

@@ -1,4 +1,4 @@
-current_version: '4.3.0a17.dev (Blue Duckling: Tulip)'
+current_version: '4.3.0a18.dev (Blue Duckling: Tulip)'
 deprecated:
 - 3.0.21
 - 3.1.20