worker.go

worker.go �{W>gU Zd>gU package main import ( "context" "fmt" "log" "math/rand" "os" "os/signal" "sync" "syscall" "time" ) func main() { ctx, cancel := context.WithCancel(context.Background()) defer cancel() sigCh := make(chan os.Signal, 1) defer close(sigCh) signal.Notify(sigCh, syscall.SIGHUP, syscall.SIGQUIT, syscall.SIGINT) go func() { <-sigCh cancel() }() d := NewDispatcher(3) for i := 0; i <