112
// HasQueue returns true if a queue exists for the given execution key.
113
// This is used by other schedulers to check if they should route tasks here.
115
>
s.mu.Lock()
116
>
defer s.mu.Unlock()
117
>
_, exists := s.queues[key]
118
>
return exists
119
>
}
120
121
// TrySubmit adds a task to its execution's queue without blocking.