Worker pool with a wait group in Go

Go

Fixed number of goroutines draining a channel, with the group ensuring main waits for all of them.

jobs := make(chan Job)
var wg sync.WaitGroup

for i := 0; i < runtime.NumCPU(); i++ {
    wg.Add(1)
    go func() {
        defer wg.Done()
        for j := range jobs {
            process(j)
        }
    }()
}

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

Download

Systems go concurrency goroutines chris

More in Systems

RAII file handling in C++ Systems The stream closes itself when it leaves scope, whether the function returns normally or throws. Check a malloc result in C Systems The allocation that nobody checks is the one that fails in production. Nullable reference types in C# Systems Turning the feature on makes the compiler point at every place a null could slip through. Read a file into a string in Go Systems os.ReadFile replaced ioutil.ReadFile in 1.16 and is the one-liner for small files. Async/await with a task group in Swift Systems Runs the downloads concurrently and collects them, with cancellation propagating to all of them. Result and the question mark operator in Rust Systems ? propagates the error to the caller, which is why Rust functions rarely need explicit error branches. Records and pattern matching in Java Systems A record plus a switch pattern removes most of the ceremony this used to take. Context with a timeout in Go Systems Cancels the request and everything downstream of it after two seconds. The defer is not optional.

Random picks

Responsive grid without media queries Web & CSS auto-fill with minmax reflows on its own, so the column count follows the container rather than a breakpoint list. Check a file's checksum Security Verifies a download actually matches what the publisher signed, rather than trusting the transfer. Parameterised tests in Python Testing One test body, many cases, and a failure that names the case that broke. A Makefile that documents itself Build & CI Running make with no arguments prints every target that carries a comment. Exhaustiveness check on a switch TypeScript Assigning to never makes the compiler fail the build when a new union member is added and left unhandled. Delete files older than thirty days Shell Prunes an archive directory without touching anything recent. Run it with -print first to see what would go. Respect a reduced-motion preference Web & CSS One rule that disables animation for people who asked their system for less of it. A semantic, accessible form field Web & CSS The label is tied to the input by id, and the hint is announced with it via aria-describedby.