国产成人精品久久免费动漫-国产成人精品天堂-国产成人精品区在线观看-国产成人精品日本-a级毛片无码免费真人-a级毛片毛片免费观看久潮喷

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

python中生產(chǎn)者消費(fèi)者線程問(wèn)題

瀏覽:126日期:2022-08-25 14:16:33

問(wèn)題描述

在使用python的多線程時(shí),使用了生產(chǎn)者消費(fèi)者模式,一般都是消費(fèi)者接受生產(chǎn)者的數(shù)據(jù)執(zhí)行某些操作,但是現(xiàn)在這個(gè)消費(fèi)者線程遇到了異常,需要終止執(zhí)行,但是生產(chǎn)者線程因?yàn)檫€在生產(chǎn)數(shù)據(jù),主線程在等待它執(zhí)行完。目前想當(dāng)消費(fèi)者線程遇到錯(cuò)誤時(shí)能夠通知生產(chǎn)者線程,我掛了,你也結(jié)束吧。請(qǐng)問(wèn)大家有什么好的實(shí)現(xiàn)方法

import threadingclass Producer(threading.Thread): def __init__(self, queue):super(Producer, self).__init__()self.queue = queue def run(self):while True: for i in range(10):self.queue.put(i)class Consumer(threading.Thread): def __init__(self, queue):super(Consumer, self).__init__()self.queue = queue def run(self):while True: try:data = self.queue.get()print dataif data == 5: raise ValueError(’over’) except ValueError as e:#通知生產(chǎn)者結(jié)束#如何實(shí)現(xiàn)?

問(wèn)題解答

回答1:

我的方法:添加一個(gè) flag 標(biāo)識(shí)。

先看結(jié)果吧:

python中生產(chǎn)者消費(fèi)者線程問(wèn)題

更多廢話也不多說(shuō)了,show u the code

#!/usr/bin/python# coding=utf-8import threadingimport timeclass Producer(threading.Thread): def __init__(self, queue, flag):super(Producer, self).__init__()self.queue = queueself.flag = flag def run(self):while True: length = max(self.queue) + 1 print '============================= producer queue', self.queue self.queue.append(length) print ’flag length=’, len(self.flag) if len(self.flag) == 0:print 'producer 我也結(jié)束了'break time.sleep(2)class Consumer(threading.Thread): def __init__(self, queue, flag):super(Consumer, self).__init__()self.queue = queueself.flag = flag def run(self):while True: try:length = len(self.queue)print 'consumer queue', self.queueif length > 5: self.flag.pop() # 注意我是flag raise ValueError(’over’)self.queue.pop(0) except ValueError as e:# 通知生產(chǎn)者結(jié)束# 如何實(shí)現(xiàn)?print 'consumer 我結(jié)束了', ebreak# raise(e) time.sleep(4)queue = [1, 2, 3]flag = [0] # 表示正常Consumer(queue, flag).start()time.sleep(1)Producer(queue, flag).start()

最后說(shuō)說(shuō)python的多線程,由于GIL的存在,其實(shí)多線程有的時(shí)候并不是最好的選擇,具體什么時(shí)候使用,網(wǎng)上也說(shuō)的很多了,樓主也可以結(jié)合自己的業(yè)務(wù)情況舍取多線程模塊。

回答2:

簡(jiǎn)單的話,就直接把錯(cuò)誤raise出來(lái),然后讓進(jìn)程自己崩潰掉就好了.或者,你也可以用異常處理把消費(fèi)者的run包裹起來(lái),捕獲這個(gè)異常,然后再控制生產(chǎn)者的線程就好了.

標(biāo)簽: Python 編程
相關(guān)文章:
主站蜘蛛池模板: 国产91第一页 | 国产在线一区二区 | 国产日韩精品一区在线不卡 | 香蕉国产人午夜视频在线观看 | 国产精品区在线12p 国产精品人成 | 久久精品片 | 亚洲精品资源网在线观看 | 一区二区亚洲精品 | 亚洲午夜大片 | 国内精品线在线观看 | 美女扒开双腿让男人爽透视频 | 91精品国产91热久久p | 99福利资源久久福利资源 | 亚洲欧洲日产v特级毛片 | 18性欧美69| 久久网站在线观看 | 日韩在线 | 中文 | 黄色大秀视频 | 欧美一级特黄特色大片 | 久久88 | 国产成人精品一区二三区2022 | 亚洲免费视频网站 | 久久最新视频 | 亚洲一区二区三区四区五区 | 免费一级成人免费观看 | 毛片三级 | 免费看成人播放毛片 | 日本不卡在线一区二区三区视频 | 亚洲一区二区中文字幕 | 久久久久久久久一级毛片 | 午夜成年人网站 | 日韩 欧美 中文 亚洲 高清 在线 | 萌白酱粉嫩jk福利视频在线观看 | 玖玖精品在线 | 国产日韩一区二区三区在线观看 | 91久久精品 | 国产丝袜美女一区二区三区 | 亚洲黄色三级网站 | ffee性xxⅹ另类老妇hd | chinese农村野战videos | 成人看片在线观看免费 |