擅长:python、mysql、java
<p>您可以在一个线程中读取更新的单词列表,并在另一个线程中使用<code>Queue</code>进行通信来处理tweet。在</p>
<h3>示例:</h3>
<p>读取tweets的线程:</p>
<pre><code>def read_tweets(q):
words = q.get()
while True:
with tweetstream.FilterStream(..track=words,..) as stream:
for tweet in stream: #NOTE:it requires special handling if it blocks
process(tweet)
try: words = q.get_nowait() # try to read a new word list
except Empty: pass
else: break # start new connection
</code></pre>
<p>读单词的线程:</p>
^{pr2}$
<p>主脚本可能看起来像:</p>
<pre><code> q = Queue(1)
t = Thread(target=read_tweets, args=(q,))
t.daemon = True
t.start()
read_words(q)
</code></pre>
<p>您可以使用<code>inotify</code>或类似方法来监视<code>'words.txt'</code>文件的更改,而不是轮询。在</p>