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 編程
相關文章:
主站蜘蛛池模板: 国产精品无码久久久久 | 中文字幕一区二区三区精彩视频 | 日韩欧美在线精品 | eeuss国产一区二区三区四区 | 国产一级片免费视频 | 日韩免费一区二区 | 国产日韩欧美一区二区 | 久久久涩 | 欧美精品一区在线发布 | 免费中文字幕日韩欧美 | 久久天堂网 | 日本免费在线观看视频 | 成人精品一区二区三区中文字幕 | 欧美亚洲视频在线观看 | 大香在线伊779 | 一区二区三区四区国产 | www.久久久 | 久久久久成人精品免费播放动漫 | 欧美日韩a | 日本五月婷婷 | 亚洲精品18 | 日本久久网| 一区二区三区四区在线 | 成人免费高清 | 欧美成人精品激情在线观看 | 久久精品成人 | 欧美三区视频 | 欧美视频在线看 | 91小视频在线 | 一区在线观看视频 | 国产精品视频一区二区三区不卡 | 国产精品成人在线 | 亚洲精品毛片av | 日本精品一区二区三区在线观看视频 | 五月槐花香 | 91伦理片| 久久综合久久综合久久综合 | 欧美亚洲国产一区二区三区 | 久久伊人在 | 国产精品毛片一区二区在线看 | 日韩在线小视频 |