启动生产者
        :param func: 生产者回调函数
        :return:

def produce(self, func):
        """
        启动生产者
        :param func: 生产者回调函数
        :return:
        """
        # 声明队列
        if not self.task_queue:
            self.ch.queue_declare(queue=self.task_queue, durable=self.durable)
        func(self)