#Simple example python program that send a signal between two threads

import gobject
import threading
import time

class knight(gobject.GObject):
    __gsignals__ = { 'chicken': (gobject.SIGNAL_RUN_FIRST, gobject.TYPE_NONE,
                                   (str,)) }
    def __init__(self) :
        #Call super()
        gobject.GObject.__init__(self)
        #Do your initialization here
        #This is only an example
        a = None
        
class tv_speaker :
    def __init__(self,emiter) :
        self.emiter = emiter
        self.emiter.connect("chicken",self.do)
        self.lock_lock = threading.Lock()
        self.main_lock = threading.Lock()
    
    #param1 is the signal itself
    def do(self,param1,param2) :
        def reallydo(param) :
            self.main_lock.acquire()
            self.lock_lock.release()
            print "receiving the chicken on the head : my brain hurt"
            time.sleep(2)
            print "And now for something completely %s" %param
            self.main_lock.release()
        if self.lock_lock.acquire(False) :
            t = threading.Thread(target=reallydo,args=[param2])
            t.start()
        else :
            print "We don't need you today"
        
class chapman :
    def __init__(self,emiter) :
        self.emiter = emiter
        
    def connect(self,signal,func) :
        self.emiter.connect(signal,func)

k = knight()
c = chapman(k)
tv = tv_speaker(c)
k.emit("chicken","different")
k.emit("chicken","random")
time.sleep(1)
k.emit("chicken","3")
k.emit("chicken","4")
k.emit("chicken","5")