Mercurial Repositories > eric / file diff

--- a/src/eric7/CodeFormatting/BlackFormattingDialog.py	Tue Aug 16 13:14:42 2022 +0200
+++ b/src/eric7/CodeFormatting/BlackFormattingDialog.py	Tue Aug 16 19:07:16 2022 +0200
@@ -272,8 +272,11 @@
         taskQueue = multiprocessing.Queue()
         doneQueue = multiprocessing.Queue()
 
-        # Submit tasks
-        for file in files:
+        # Submit tasks (initially two times the number of processes)
+        tasks = len(files)
+        initialTasks = 2 * NumberOfProcesses
+        for _ in range(initialTasks):
+            file = files.pop(0)
             relSrc = self.__project.getRelativePath(str(file)) if self.__project else ""
             taskQueue.put((file, relSrc))
 
@@ -289,7 +292,7 @@
             worker.start()
 
         # Get the results from the worker tasks
-        for _ in range(len(files)):
+        for _ in range(tasks):
             result = doneQueue.get()
             self.__handleBlackFormattingResult(
                 result.status, result.filename, result.data
@@ -298,13 +301,16 @@
             if self.__cancelled:
                 break
 
-        if self.__cancelled:
-            for worker in workers:
-                worker.terminate()
-        else:
-            # Tell child processes to stop
-            for _ in range(NumberOfProcesses):
-                taskQueue.put("STOP")
+            if files:
+                file = files.pop(0)
+                relSrc = (
+                    self.__project.getRelativePath(str(file)) if self.__project else ""
+                )
+                taskQueue.put((file, relSrc))
+
+        # Tell child processes to stop
+        for _ in range(NumberOfProcesses):
+            taskQueue.put("STOP")
 
         for worker in workers:
             worker.join()