'The initial function of the thread.'

def run(self):

    while (not self.my_thread_ended):
        try:
            msg = self.inputqueue.get(timeout=1)
        except Queue.Empty:
            pass
        else:
            self.repository.append(msg)
