343 # Tell child processes to stop |
343 # Tell child processes to stop |
344 for _ in range(NumberOfProcesses): |
344 for _ in range(NumberOfProcesses): |
345 taskQueue.put("STOP") |
345 taskQueue.put("STOP") |
346 |
346 |
347 for worker in workers: |
347 for worker in workers: |
348 worker.join(2) # 2 seconds timeout just in case |
348 worker.join() |
349 # TODO: monitor this change |
|
350 if worker.exitcode is None: |
|
351 worker.terminate() |
|
352 worker.close() |
349 worker.close() |
353 |
350 |
354 taskQueue.close() |
351 taskQueue.close() |
355 ## doneQueue.close() |
352 doneQueue.close() |
356 # TODO: monitor this change |
|
357 |
353 |
358 self.__finish() |
354 self.__finish() |
359 |
355 |
360 @staticmethod |
356 @staticmethod |
361 def formattingWorkerTask(inputQueue, outputQueue, config): |
357 def formattingWorkerTask(inputQueue, outputQueue, config): |