Target function of workers

def worker_exec(self, **kwargs):
        """Target function of workers"""
        self.feed(**kwargs)
        self.logger.info('thread {} exit'.format(current_thread().name))