擅长:python、mysql、java
<p>如果db是一个消息队列,那么我只会在这个队列中添加一些“quit”假消息。
下面是一些伪代码。你知道吗</p>
<pre><code>class MessageThread(Thread):
def __init__(self, db, worker_inbox, *args, **kwargs):
super(MessageThread, self).__init__(*args, **kwargs)
self.db = db
self.worker_inbox = worker_inbox # this is a stdlib Queue.Queue
def run(self):
while True:
message = self.db.get()
if "quit" == message:
return
self.worker_inbox.put(message)
def quit(self):
self.db.put("quit")
a = MessageThread()
a.start()
sleep(1.0)
a.quit()
a.join()
</code></pre>