Feladat: „Párhuzamos URL-feldolgozás időkorláttal” Írjon egy függvényt fetchAll(urls []string, maxParallel int, timeout time.Duration) map[string]string, az: 1. Minden URL esetén HTTP GET-kérést hajt végre (használható az http.Get). 2. Visszaad egy map[string]string-et, ahol a kulcs az URL, az érték pedig a válasz törzse (stringként), vagy üres string hiba/időkorlát esetén. 3. Legfeljebb maxParallel kérés fut egyszerre. 4. A függvény összes futási ideje nem haladhatja meg a timeout-ot. Ha az idő lejár, minden be nem fejezett kérés megszakad, és a függvény visszaadja, amit sikerült. 5. Használja a context-et a megszakításhoz.

go package main

import ( "context" "io/ioutil" "net/http" "sync" "time" )

func fetchAll(urls []string, maxParallel int, timeout time.Duration) map[string]string { ctx, cancel := context.WithTimeout(context.Background(), timeout) defer cancel()

results := make(map[string]string)
var mu sync.Mutex
sem := make(chan struct{}, maxParallel) // semaphore για τον περιορισμό του παραλληλισμού
var wg sync.WaitGroup

for _, url := range urls {
	select {
	case <-ctx.Done():
		break
	default:
		wg.Add(1)
		sem <- struct{}{} // κρατάμε μια θέση

		go func(u string) {
			defer wg.Done()
			defer func() { <-sem }() // ελευθερώνουμε τη θέση

			req, err := http.NewRequestWithContext(ctx, "GET", u, nil)
			if err != nil {
				mu.Lock()
				results[u] = ""
				mu.Unlock()
				return
			}

			resp, err := http.DefaultClient.Do(req)
			if err != nil {
				mu.Lock()
				results[u] = ""
				mu.Unlock()
				return
			}
			defer resp.Body.Close()

			body, err := ioutil.ReadAll(resp.Body)
			if err != nil {
				mu.Lock()
				results[u] = ""
				mu.Unlock()
				return
			}

			mu.Lock()
			results[u] = string(body)
			mu.Unlock()
		}(url)
	}
}

wg.Wait()
return results

}