Added code to explicitly close the queues to/from the workers at the end of a batch check. eric7

Wed, 03 Aug 2022 11:54:32 +0200

author
Detlev Offenbach <detlev@die-offenbachs.de>
date
Wed, 03 Aug 2022 11:54:32 +0200
branch
eric7
changeset 9279
e252f827aaa7
parent 9278
36448ca469c2
child 9280
94f4e2751790

Added code to explicitly close the queues to/from the workers at the end of a batch check.

src/eric7/Plugins/CheckerPlugins/CodeStyleChecker/CodeStyleChecker.py file | annotate | diff | comparison | revisions
src/eric7/Plugins/CheckerPlugins/SyntaxChecker/SyntaxCheck.py file | annotate | diff | comparison | revisions
src/eric7/Plugins/CheckerPlugins/SyntaxChecker/jsCheckSyntax.py file | annotate | diff | comparison | revisions
src/eric7/Plugins/CheckerPlugins/SyntaxChecker/jsonCheckSyntax.py file | annotate | diff | comparison | revisions
src/eric7/Plugins/CheckerPlugins/SyntaxChecker/tomlCheckSyntax.py file | annotate | diff | comparison | revisions
src/eric7/Plugins/CheckerPlugins/SyntaxChecker/yamlCheckSyntax.py file | annotate | diff | comparison | revisions
--- a/src/eric7/Plugins/CheckerPlugins/CodeStyleChecker/CodeStyleChecker.py	Fri Jul 29 16:29:31 2022 +0200
+++ b/src/eric7/Plugins/CheckerPlugins/CodeStyleChecker/CodeStyleChecker.py	Wed Aug 03 11:54:32 2022 +0200
@@ -269,6 +269,9 @@
     for worker in workers:
         worker.join()
         worker.close()
+    
+    taskQueue.close()
+    doneQueue.close()
 
 
 def workerTask(inputQueue, outputQueue):
--- a/src/eric7/Plugins/CheckerPlugins/SyntaxChecker/SyntaxCheck.py	Fri Jul 29 16:29:31 2022 +0200
+++ b/src/eric7/Plugins/CheckerPlugins/SyntaxChecker/SyntaxCheck.py	Wed Aug 03 11:54:32 2022 +0200
@@ -190,6 +190,9 @@
     for worker in workers:
         worker.join()
         worker.close()
+    
+    taskQueue.close()
+    doneQueue.close()
 
 
 def workerTask(inputQueue, outputQueue):
--- a/src/eric7/Plugins/CheckerPlugins/SyntaxChecker/jsCheckSyntax.py	Fri Jul 29 16:29:31 2022 +0200
+++ b/src/eric7/Plugins/CheckerPlugins/SyntaxChecker/jsCheckSyntax.py	Wed Aug 03 11:54:32 2022 +0200
@@ -139,6 +139,9 @@
     for worker in workers:
         worker.join()
         worker.close()
+    
+    taskQueue.close()
+    doneQueue.close()
 
 
 def workerTask(inputQueue, outputQueue):
--- a/src/eric7/Plugins/CheckerPlugins/SyntaxChecker/jsonCheckSyntax.py	Fri Jul 29 16:29:31 2022 +0200
+++ b/src/eric7/Plugins/CheckerPlugins/SyntaxChecker/jsonCheckSyntax.py	Wed Aug 03 11:54:32 2022 +0200
@@ -140,6 +140,9 @@
     for worker in workers:
         worker.join()
         worker.close()
+    
+    taskQueue.close()
+    doneQueue.close()
 
 
 def workerTask(inputQueue, outputQueue):
--- a/src/eric7/Plugins/CheckerPlugins/SyntaxChecker/tomlCheckSyntax.py	Fri Jul 29 16:29:31 2022 +0200
+++ b/src/eric7/Plugins/CheckerPlugins/SyntaxChecker/tomlCheckSyntax.py	Wed Aug 03 11:54:32 2022 +0200
@@ -140,6 +140,9 @@
     for worker in workers:
         worker.join()
         worker.close()
+    
+    taskQueue.close()
+    doneQueue.close()
 
 
 def workerTask(inputQueue, outputQueue):
--- a/src/eric7/Plugins/CheckerPlugins/SyntaxChecker/yamlCheckSyntax.py	Fri Jul 29 16:29:31 2022 +0200
+++ b/src/eric7/Plugins/CheckerPlugins/SyntaxChecker/yamlCheckSyntax.py	Wed Aug 03 11:54:32 2022 +0200
@@ -140,6 +140,9 @@
     for worker in workers:
         worker.join()
         worker.close()
+    
+    taskQueue.close()
+    doneQueue.close()
 
 
 def workerTask(inputQueue, outputQueue):

eric ide

mercurial