golang timeout1 (每个子任务超时)

golang_timeout1.go

package main

import (
	"fmt"
	"time"
)

func add(ch chan int) {
	for i := 0; i < 10; i++ {
		ch <- i
	}
}

func main() {
	ch := make(chan int, 10)
	go add(ch)
	for {
		select {
		case <-time.After(2 * time.Second):
			fmt.Println("timeout")
			return
		case <-ch:
			fmt.Println("sleep one seconds ...")
			time.Sleep(1 * time.Second)
		}
	}
}