大家来解惑--这段代码有啥问题？

javasgl · · 2876 次点击

``` package main import ( "fmt" "time" ) func main() { limiter := make(chan bool, 10) for i := 0; i < 100; i++ { limiter <- true go download(i, limiter) } } func download(index int, limiter chan bool) { time.Sleep(1 * time.Second) fmt.Println("start to download :", index) <-limiter } ``` 上面这段代码执行结果为什么最大打印值直到 89 ？当把 ``` time.Sleep(1 * time.Second) fmt.Println("start to download :", index) ``` 两行上下调换之后，变成以下的代码： ``` fmt.Println("start to download :", index) time.Sleep(1 * time.Second) ``` 就能正常打印到 99 了？

阅读全文

查看全部 32 个评论

javasgl

这个 `curGNum`的没有自增操作么？如果要在`goroutinue`里面对`curGNum`自增操作的话，需要对这个进行加锁吧。想通了，通过` sync.WaitGroup `和 `channel `实现了控制并发数，代码如下： ``` package main import ( "fmt" "sync" "time" ) func main() { wg := &sync.WaitGroup{} limiter := make(chan bool, 10) for i := 0; i < 100; i++ { wg.Add(1) limiter <- true go download(i, limiter, wg) } wg.Wait() } func download(index int, limiter chan bool, wg *sync.WaitGroup) { defer wg.Done() fmt.Println("start to download :", index) time.Sleep(1 * time.Second) <-limiter } ```

评论于 2017-09-18 00:44:46

#9

更多评论