|
|
@@ -2,21 +2,26 @@ from library.analysis import testSets, generators, runExercise
|
|
|
import os
|
|
|
import threading
|
|
|
|
|
|
+maxWorkers = 6
|
|
|
+doMultitask = False
|
|
|
|
|
|
nWorker = 0
|
|
|
|
|
|
for dataset in testSets:
|
|
|
for name in generators.keys():
|
|
|
- nWorker += 1
|
|
|
- if 0 == os.fork():
|
|
|
- print(f"#{nWorker}: start: {name}({dataset})")
|
|
|
- runExercise(dataset, None, name, generators[name])
|
|
|
- print(f"#{nWorker}: end.")
|
|
|
- exit()
|
|
|
+ if doMultitask:
|
|
|
+ nWorker += 1
|
|
|
+ if 0 == os.fork():
|
|
|
+ print(f"#{nWorker}: start: {name}({dataset})")
|
|
|
+ runExercise(dataset, None, name, generators[name])
|
|
|
+ print(f"#{nWorker}: end.")
|
|
|
+ exit()
|
|
|
+ else:
|
|
|
+ if nWorker >= 6:
|
|
|
+ os.wait()
|
|
|
+ nWorker -= 1
|
|
|
else:
|
|
|
- if nWorker >= 2:
|
|
|
- os.wait()
|
|
|
- nWorker -= 1
|
|
|
+ runExercise(dataset, None, name, generators[name])
|
|
|
|
|
|
while nWorker > 0:
|
|
|
os.wait()
|