Go Distributed System

package worker

import (
    "context"
    "sync"
)

type WorkerPool struct {
    jobs    chan Job
    results chan Result
    wg      sync.WaitGroup
}

func (wp *WorkerPool) Start(ctx context.Context, n int) {
    for i := 0; i < n; i++ {
        wp.wg.Add(1)
        go wp.worker(ctx)
    }
}

func (wp *WorkerPool) worker(ctx context.Context) {
    defer wp.wg.Done()
    for job := range wp.jobs {
        select {
        case <-ctx.Done():
            return
        default:
            result := job.Execute(ctx)
            wp.results <- result
        }
    }
}