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

您的位置:首頁技術文章
文章詳情頁

python中生產者消費者線程問題

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

問題描述

在使用python的多線程時,使用了生產者消費者模式,一般都是消費者接受生產者的數據執行某些操作,但是現在這個消費者線程遇到了異常,需要終止執行,但是生產者線程因為還在生產數據,主線程在等待它執行完。目前想當消費者線程遇到錯誤時能夠通知生產者線程,我掛了,你也結束吧。請問大家有什么好的實現方法

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:#通知生產者結束#如何實現?

問題解答

回答1:

我的方法:添加一個 flag 標識。

先看結果吧:

python中生產者消費者線程問題

更多廢話也不多說了,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 我也結束了'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:# 通知生產者結束# 如何實現?print 'consumer 我結束了', ebreak# raise(e) time.sleep(4)queue = [1, 2, 3]flag = [0] # 表示正常Consumer(queue, flag).start()time.sleep(1)Producer(queue, flag).start()

最后說說python的多線程,由于GIL的存在,其實多線程有的時候并不是最好的選擇,具體什么時候使用,網上也說的很多了,樓主也可以結合自己的業務情況舍取多線程模塊。

回答2:

簡單的話,就直接把錯誤raise出來,然后讓進程自己崩潰掉就好了.或者,你也可以用異常處理把消費者的run包裹起來,捕獲這個異常,然后再控制生產者的線程就好了.

標簽: Python 編程
相關文章:
主站蜘蛛池模板: 国产精品自拍视频 | 国产精品久久久亚洲 | 日韩电影免费在线观看中文字幕 | 美女天天操 | 9久久精品 | 国产成人高清成人av片在线看 | 欧美一级片在线观看 | 欧美三区在线观看 | 国产乱码精品一区二区三区中文 | 欧美一级久久 | 久久亚洲综合 | 欧美456| 综合国产在线 | 99久久久久久 | 在线看黄免费 | 暖暖成人免费视频 | 精品久久网 | 成年网站在线观看 | 男女羞羞免费视频 | 亚洲免费在线观看 | 一区二区三区福利视频 | 欧美成人aaa级毛片在线视频 | 2019精品手机国产品在线 | 日韩成人免费视频 | 99re| 午夜精品久久久久久久99黑人 | 中文成人无字幕乱码精品 | 超碰97免费 | 精品麻豆剧传媒av国产九九九 | 视频1区| 国产精品一区二区在线 | 国产一区二区三区久久久久久久久 | 日韩 欧美 综合 | 国产精品黄色 | 日本三级电影在线看 | 成人在线小视频 | 亚洲欧美中文字幕 | 久久av一区 | 九九热精品视频 | 欧美日韩一 | 国产精品欧美一区二区三区 |