循环获取channel

func get(data chan int){    for v,ok := range chan{        if !ok{            //channel 已经关闭
            break
        }        // do something with v
    }
}

如果需要停止使用channel，需要手动将channel关闭

close(data)

关闭后的channel还能获取其中存在的数据，但是不能再增加数据。数据取完后ok值为false。

channel关闭的判断

ch = make(chan int, 10)//....some codeselect{    case r,ok := <- ch:    if !ok  {        //通道已空 并且已经关闭
    }
}

向有缓存的channel传数据，满了就停止，不阻塞

ch = make(chan int, 10)

Fill: //为循环设置tagfor{    select {        case ch <- 1:        default:            break Fill
    }
}

for循环必须设置tag，不然select中的break无法停止外部循环，会一直执行default，陷入死循环。

//这段代码会陷入死循环中，每次都执行defaultfor{    select{    case <- time.After(10*time.Second):    default:        break
    }
}

超时的使用

select{    case job <- jobList    case <- time.After(10 * time.Second):    //10秒后做超时处理}

原文