Method RemoveAsync

server/cache/file_cache.go:339–364

RemoveAsync removes an entry from cache asynchronously using worker pool

(key string)

// RemoveAsync removes an entry from cache asynchronously using worker pool
func (fc *FileCache) RemoveAsync(key string) {
	// First check if cache is closed
	fc.closeMutex.RLock()
	if fc.closed {
		fc.closeMutex.RUnlock()
		return
	}
	fc.closeMutex.RUnlock()

	// Try to acquire a worker from the pool
	select {
	case <-fc.workerPool:
		// Got a worker, proceed with async removal
		go func() {
			defer func() {
				// Return worker to pool
				fc.workerPool <- struct{}{}
			}()
			fc.Remove(key)
		}()
	default:
		// Worker pool exhausted, remove synchronously to prevent memory leak
		log.Debugf("Worker pool exhausted, removing cache entry synchronously: %s", key)
		fc.Remove(key)
	}
}