Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- import threading
- import Queue
- import time
- class ResultWriter(threading.Thread):
- def __init__(self, queue):
- threading.Thread.__init__(self)
- self.q = queue
- def run(self):
- f = open('foo.txt', 'a')
- while True:
- try:
- item = self.q.get(False)
- f.write(item)
- f.flush()
- except Queue.Empty:
- # re-check queue for messages every x sec
- time.sleep(.01)
- class Foo(threading.Thread):
- def __init__(self):
- threading.Thread.__init__(self)
- def run(self):
- q = Queue.Queue(0)
- t = ResultWriter(q)
- t.setDaemon(True)
- t.start()
- while True:
- print 'foo'
- q.put('foo')
- f = Foo()
- f.setDaemon(True)
- f.start()
- while True:
- time.sleep(.1)
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement