Написал скрипт, который в двух процессах анализирует архивы с текстовыми файлами, результаты вносит в MySQL. Вот вкратце как он работает:
Я с помощью
queue = JoinableQueue()
queue.put(file_name)
input_filename = queue.get()
input_filename != None
queue.task_done()
Да, в основном процессе в это время я нахожусь в ожидании завершения обработки подпроцессами набора заданий, т.е. нахожусь на команде
queue.join()
Traceback (most recent call last):
File “D:\Install\Programming\eclipse\plugins\org.python.pydev_2.7.1.2012100913\pysrc\pydevd.py”, line 1397, in <module>
debugger.run(setup, None, None)
File “D:\Install\Programming\eclipse\plugins\org.python.pydev_2.7.1.2012100913\pysrc\pydevd.py”, line 1090, in run
pydev_imports.execfile(file, globals, locals) #execute the script
File “D:\Documents\My\Programming\Eclipse workspace\python_file_processing\main_module.py”, line 108, in <module>
workers.terminate()
File “C:\Python27\lib\multiprocessing\process.py”, line 137, in terminate
self._popen.terminate()
File “C:\Python27\lib\multiprocessing\forking.py”, line 306, in terminate
_subprocess.TerminateProcess(int(self._handle), TERMINATE)
WindowsError:
Какова фига - хз. Как это исследовать?
108-я строчка main_module.py вот (она крутится в цикле, j=0 или 1:
workers[j].terminate()