av一区二区在线观看_亚洲男人的天堂网站_日韩亚洲视频_在线成人免费_欧美日韩精品免费观看视频_久草视

您的位置:首頁技術(shù)文章
文章詳情頁

Python多進程池。當(dāng)工作進程之一確定不再需要執(zhí)行更多工作時,如何退出腳本?

瀏覽:3日期:2022-08-07 10:12:51
如何解決Python多進程池。當(dāng)工作進程之一確定不再需要執(zhí)行更多工作時,如何退出腳本??

您可以使用中的回調(diào)Pool.apply_async。

這樣的事情應(yīng)該可以為您完成工作。

from multiprocessing import Pooldef part_crack_helper(args): solution = do_job(args) if solution:return True else:return Falseclass Worker(): def __init__(self, workers, initializer, initargs):self.pool = Pool(processes=workers, initializer=initializer, initargs=initargs) def callback(self, result):if result: print 'Solution found! Yay!' self.pool.terminate() def do_job(self):for args in product(seed_str, repeat=4): self.pool.apply_async(part_crack_helper, args=args, callback=self.callback)self.pool.close()self.pool.join()print 'good bye'w = Worker(num_proc, init, [total_count])w.do_job()解決方法

mp.set_start_method(’spawn’)total_count = Counter(0)pool = mp.Pool(initializer=init,initargs=(total_count,),processes=num_proc)pool.map(part_crack_helper,product(seed_str,repeat=4))pool.close()pool.join()

因此,我有一組工作人員在做一些工作。它只需要找到一個解決方案。因此,當(dāng)一個工作進程找到解決方案時,我想停止一切。

我想到的一種方法是只調(diào)用sys.exit()。但是,由于其他進程正在運行,因此似乎無法正常工作。

另一種方法是檢查每個進程調(diào)用的返回值(part_crack_helper函數(shù)的返回值),然后在該進程上終止調(diào)用。但是,我不知道在使用該map函數(shù)時該怎么做。

我應(yīng)該如何實現(xiàn)?

標簽: Python 編程
主站蜘蛛池模板: 国产亚洲欧美在线 | 性一交一乱一伦视频免费观看 | 天天射天天操天天干 | 国产美女高潮 | 色婷婷狠狠 | 日本黄色片免费在线观看 | 成人免费视频7777777 | 国产剧情一区 | 天天干天天想 | 九九热最新视频 | 四虎伊人| 久久tv在线观看 | 色接久久 | 久久精品一区 | 国际精品鲁一鲁一区二区小说 | 日韩三片 | 奇米久久 | 久久久久久久久久久久久91 | 久久99成人 | 一区在线播放 | 中国一级特黄真人毛片 | 黄网站在线播放 | 亚洲国产成人精品女人久久久 | 久久精品1| 亚洲视频一区 | 精品无码久久久久久久动漫 | 91精品久久久久久久久 | 一区不卡在线观看 | 伊人伊成久久人综合网站 | 国产日韩亚洲欧美 | 国产精品有限公司 | 欧美乱码精品一区二区三区 | 91看片网 | 国产精品欧美一区二区三区不卡 | 久久人人网 | 日韩国产黄色片 | 天天搞天天操 | 久久69精品久久久久久久电影好 | 欧美成人一区二区 | 日韩中文字幕一区 | 美女日皮网站 |