parallel_search.go

func ParallelSearch(query string) []SearchResult {
	ctx, cancel := context.WithTimeout(context.Background(), 750*time.Millisecond)
	defer cancel()

	resultsChan := make(chan []SearchResult, len(backends))
	var wg sync.WaitGroup

	for _, backend := range backends {
		wg.Add(1)
		go func(backend func(string) ([]SearchResult, error)) {
			defer wg.Done()
			results, err := backend(query)
			if err != nil {
				return
			}
			select {
			case resultsChan <- results:
			case <-ctx.Done():
			}
		}(backend)
	}

	wg.Wait()
	close(resultsChan)

	var combined []SearchResult
	for res := range resultsChan {
		combined = append(combined, res...)
	}

	return combined
}