Python | import threading import Queue - Corey g - f261f398f

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)