Function NewAsyncExecutor

ai-provider/local/executor.go:125–136

NewAsyncExecutor 创建一个新的异步任务执行器

(queueSize int)

// NewAsyncExecutor 创建一个新的异步任务执行器
func NewAsyncExecutor(queueSize int) *AsyncExecutor {
	ctx, cancel := context.WithCancel(context.Background())
	executor := &AsyncExecutor{
		ctx:       ctx,
		cancel:    cancel,
		pipelines: make(map[string]*modelPipeline), // 以模型为 key，存管道列表
		msgQueue:  make(chan messageTask, queueSize),
	}
	executor.StartMessageDistributor()

	return executor
}

func (e *AsyncExecutor) GetModelPipeline(model string) (*modelPipeline, bool) {
	e.mu.Lock()