Method Execute

pkg/tools/executor.go:59–98

Execute 执行单个工具

(ctx context.Context, req *ExecuteRequest)

// Execute 执行单个工具
func (e *Executor) Execute(ctx context.Context, req *ExecuteRequest) *ExecuteResult {
	startTime := time.Now()

	// 获取信号量
	select {
	case e.semaphore <- struct{}{}:
		defer func() { <-e.semaphore }()
	case <-ctx.Done():
		return &ExecuteResult{
			Success:   false,
			Error:     ctx.Err(),
			StartedAt: startTime,
			EndedAt:   time.Now(),
		}
	}

	// 设置超时
	timeout := req.Timeout
	if timeout <= 0 {
		timeout = e.config.DefaultTimeout
	}

	execCtx, cancel := context.WithTimeout(ctx, timeout)
	defer cancel()

	// 执行工具
	output, err := req.Tool.Execute(execCtx, req.Input, req.Context)
	endTime := time.Now()

	result := &ExecuteResult{
		Success:    err == nil,
		Output:     output,
		Error:      err,
		StartedAt:  startTime,
		EndedAt:    endTime,
		DurationMs: endTime.Sub(startTime).Milliseconds(),
	}

	return result
}

// ExecuteBatch 批量执行工具
func (e *Executor) ExecuteBatch(ctx context.Context, requests []*ExecuteRequest) []*ExecuteResult {