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