Method StartMessageDistributor

ai-provider/local/executor.go:176–191

StartMessageDistributor 启动消息分发器

()

// StartMessageDistributor 启动消息分发器
func (e *AsyncExecutor) StartMessageDistributor() {
	go func() {
		for task := range e.msgQueue {
			msg := task.message
			e.DistributeToModelPipelines(msg.Model, msg)
			if msg.Status == "error" || msg.Status == "success" {
				mp, has := e.GetModelPipeline(msg.Model)
				if has && mp.pullFn != nil {
					mp.pullFn(msg)
				}
				e.CloseModelPipeline(msg.Model)
				continue
			}
		}
	}()
}

// DistributeToModelPipelines 仅将消息分发给指定模型的管道
func (e *AsyncExecutor) DistributeToModelPipelines(model string, msg PullMessage) {