【发布时间】:2023-04-06 01:58:01
【问题描述】:
我尝试了一些多进程示例,主要是:http://toastdriven.com/blog/2008/nov/11/brief-introduction-multiprocessing/ 我采用了“简单应用程序”,它使用多进程来测试 URL。
当我使用它(在 Python 3.3 中,在 Windows 中的 PyCharm IDE 中)进行一些修改时,有很多 URL,我的脚本永远不会停止,我不明白为什么。
import httplib2
import sys
from multiprocessing import Lock, Process, Queue, current_process
def worker(work_queue, done_queue):
for url in iter(work_queue.get, 'STOP'):
try:
print("In : %s - %s." % (current_process().name, url))
status_code = print_site_status(url)
done_queue.put("%s - %s got %s." % (current_process().name, url, status_code))
except:
done_queue.put("%s failed on %s with: %s" % (current_process().name, url, str(sys.exc_info()[0])))
print("Out : %s " % (current_process().name))
return True
def print_site_status(url):
http = httplib2.Http(timeout=10)
headers, content = http.request(url)
return headers.get('status', 'no response')
def main():
workers = 8
work_queue = Queue()
done_queue = Queue()
processes = []
with open("Annu.txt") as f: # file with URLs
lines = f.read().splitlines()
for surl in lines:
work_queue.put(surl)
for w in range(workers):
p = Process(target=worker, args=(work_queue, done_queue))
p.start()
processes.append(p)
work_queue.put('STOP')
for p in processes:
p.join()
print("END")
done_queue.put('STOP')
for status in iter(done_queue.get, 'STOP'):
print(status)
if __name__ == '__main__':
main()
我清楚地看到了所有已测试的 URL 状态,以及表明进程结束的所有进程“Out”消息,但从来没有看到我的“END”消息。
我使用的 URL 列表是:http://www.pastebin.ca/2946850。
那么...我的错误在哪里?是否与:Python multiprocessing threads never join when given large amounts of work 重复?
一些信息:当我在代码中的任何地方禁止“done_queue”时:它是有效的。
【问题讨论】:
-
注意END不会像你想的那样打印在END。向上滚动接近一半,您会在那里看到它。
-
@dopstar 抱歉,您的评论不清楚,您是否说“END”消息不在脚本末尾?如果是:我知道,'END' 在这里表示进程已结束。
-
在打印完 END 后,您还打印了完成队列中的状态,因此这会将 END 大致放在中间。您有 500 多个网址,因此您将有 1k 多个打印输出,中间某处有 END。
-
我已经确认这会在中间某处打印出 END。运行后检查脚本的输出:paste.ubuntu.com/10501008。 END 在第 553 行。
-
@dopstar 我看到了你的打印(谢谢!),结果对我来说没问题:'END'消息在'Out:Process-x'之后(并且在'Process -x - xxxxx' 个)。但是,在我的情况下,“Out:Process-x”消息是最后一个!没有“结束”:我有 (+/-) 500 个打印而不是 1000。可能是 Windows 配置问题...
标签:
python
python-3.x
multiprocessing
本站文章如无特殊说明,均为本站原创,如若转载,请注明出处:为什么我的多进程 Python 脚本永远不会结束? - Python技术站