Observer thread

observe_thread.py

import threading
import time

class Worker(threading.Thread):
    def __init__(self):
        threading.Thread.__init__(self)
        self.val = 0
        self.val2 = 20

    def run(self):
        while 1:
            time.sleep(1)
            self.val += 1


class Observer(threading.Thread):
    def __init__(self, worker):
        threading.Thread.__init__(self)
        self.worker = worker

    def run(self):
        while 1:
            print self.worker.val
            time.sleep(1)

w = Worker()
w.start()

o = Observer(w)
o.start()