Method launch

agent/tools_executor.go:360–376

(tcID string)

		return false
	}
	return true
}

func (e *StreamingToolExecutor) isSafeLocked(tc coretools.ToolCall) bool {
	tool := e.Registry.Get(tc.Name)
	if tool == nil {
		return false
	}
	input, err := tool.DecodeInput(tc.Input)
	if err != nil {
		input = nil
	}
	return tool.IsConcurrencySafe(input)
}

func (e *StreamingToolExecutor) launch(tcID string) {
	e.mu.Lock()
	slot := e.slots[tcID]
	if slot == nil || slot.State != ToolStateQueued {
		e.mu.Unlock()