缓存channel使用for-range？

bvaccc · 2016-12-23 07:47:04 · 1752 次点击

代码如下：

package main

import (
    "fmt"
    "runtime"
)

func main() {
    runtime.GOMAXPROCS(runtime.NumCPU())
    c := make(chan bool, 10)
    for i := 0; i < 10; i++ {
        go Go(c, i)
    }
    for i := 0; i < 10; i++ { //如何使用`for-range`循环实现？
        <-c
    }
}

func Go(c chan bool, index int) {
    a := 0
    for i := 0; i < 10000000; i++ {
        a += i
    }
    fmt.Println(index, a)

    c <- true
}

求解。

阅读全文

查看全部 9 个评论

jmzwcn

for len(queue) > 0 { value := <-queue fmt.Println(value) }

评论于 2016-12-23 10:43:50

#6

更多评论

stevewang

耶和华是我的牧者，我必不至缺乏。

这里不适合用range，因为需要配合close，但是找不到合适的地方去close channel

评论于 2016-12-23 08:36:27

#1

abin

package main

import ( "fmt" "runtime" )

func main() { runtime.GOMAXPROCS(runtime.NumCPU()) cs := make([]chan bool, 10) for i := 0; i < 10; i++ { cs[i] = make(chan bool, 1) go Go(cs[i], i) } for _, c := range cs { <-c } }

func Go(c chan bool, index int) { a := 0 for i := 0; i < 10000000; i++ { a += i } fmt.Println(index, a)

c <- true

}

改成slice试试？

评论于 2016-12-23 09:19:38

#2

我要评论

缓存channel使用for-range？

用户登录

今日阅读排行

一周阅读排行