Silenced debug and fixed multiprocessing

GFAstats.py

@@ -296,7 +296,7 @@ for query_id in range(len(all_paths[:-1])):
     for target_id in range(query_id+1, len(all_paths)):  
         query, target = all_paths[query_id], all_paths[target_id]
         value = get_shared_nodes(query, target)
-        if args.progress: print(f"[GFAstats::{panname}]\tFound {len(value)}")
+        #if args.progress: print(f"[GFAstats::{panname}]\tFound {len(value)}")
         shared_nodes[(query, target)] = value
 
 def get_shared_content(query, pathDict=pathStats, nodesLengthDict=nodesLengthDict, shared_nodes=shared_nodes, showProgress=args.progress, panname=panname):
@@ -317,7 +317,7 @@ def get_shared_content(query, pathDict=pathStats, nodesLengthDict=nodesLengthDic
                 _shared = set(shared_nodes[(target, query)])
             
             # Number of shared nodes traversing the current path (without repeats)
-            print(len(_shared))
+            #print(len(_shared))
             _stats[target]["shared.nodes.count"] = len(_shared)
         
             # Length of shared nodes traversing the current path (without repeats)
@@ -325,7 +325,7 @@ def get_shared_content(query, pathDict=pathStats, nodesLengthDict=nodesLengthDic
                 nodesLengthDict[nodeid] 
                 for nodeid in _shared
             ])
-            print("without repeats : ", _stats[target]["shared.length"])
+            #print("without repeats : ", _stats[target]["shared.length"])
             
             # Length of shared nodes traversing the current path (with repeats)
             _stats[target]["shared.R.length"] = np.sum([ 
@@ -333,12 +333,12 @@ def get_shared_content(query, pathDict=pathStats, nodesLengthDict=nodesLengthDic
                 for nodeid in pathDict[query]["Path.nodes"]
                 if nodeid in _shared
             ])
-            print("with repeats : ", _stats[target]["shared.R.length"])
+            #print("with repeats : ", _stats[target]["shared.R.length"])
     
     return _stats
 
 # Multithreading the path statistics retrieving
-executor = concurrent.futures.ThreadPoolExecutor(max_workers=1)
+executor = concurrent.futures.ThreadPoolExecutor(max_workers=args.threads)
 res = {}
 for pathname in pathStats.keys():
     res[pathname] = executor.submit(get_shared_content, pathname)