worker.go

timer := time.NewTimer(timeout)
for {
    select {
    case task = <-ws.ch:
        if !timer.Stop() {
            <-timer.C
        }
        timer.Reset(timeout)
        run(task)
    case <-timer.C:
        return // idle timeout, worker terminates
    }
}