Master Software Architecture & AI with HelloAIHub

package main

import (
    "context"
    "fmt"
    "sync"
)

// ProcessJobs executes tasks concurrently with bounded worker pools
func ProcessJobs(ctx context.Context, concurrency int, jobs []int) {
    ch := make(chan int, concurrency)
    var wg sync.WaitGroup

    for i := 0; i < concurrency; i++ {
        wg.Add(1)
        go func(workerId int) {
            defer wg.Done()
            for job := range ch {
                fmt.Printf("[Worker #%d] Executing Task #%d
", workerId, job)
            }
        }(i)
    }

    for _, j := range jobs {
        ch <- j
    }
    close(ch)
    wg.Wait()
}