Go 并发控制

go并发控制.go

package main

import "log"
import "time"
import "sync"

var(
    ch chan int
    wg sync.WaitGroup
)

func init(){
    ch = make(chan int,4)
}

func main() {
    for i:=0; i<10; i++ {
        ch <- i
        wg.Add(1)
        go func(x int){
            defer func(){
                i := <- ch
                log.Println("i = ",i)
                wg.Done()
            }()
            log.Println("休眠前",x)
            time.Sleep(time.Second)
        }(i)
    }
    wg.Wait()
}