go语言channel的别样用法

func main() {
 // 生成随机数作为一个服务
 randService := randGenerator()
 // 从服务中读取随机数并打印
 fmt.Printf("%d\n",<-randService)
}
func randGenerator() chan int {
 // 创建通道
 out := make(chan int)
 // 创建协程
 go func() {
 for {
 //向通道内写入数据,如果无人读取会等待
 out <- rand.Int()
 }
 }()
 return out
}

//一个查询结构体
type query struct {
 //参数Channel
 sql chan string
 //结果Channel
 result chan string
}
//执行Query
func execQuery(q query) {
 //启动协程
 go func() {
 //获取输入
 sql := <-q.sql
 //访问数据库,输出结果通道
 q.result <- "get" + sql
 }()
}
func main() {
 //初始化Query
 q := query{make(chan string, 1),make(chan string, 1)}
 //执行Query,注意执行的时候无需准备参数
 execQuery(q)
 //准备参数
 q.sql <- "select * from table"
 //获取结果
 fmt.Println(<-q.result)
}

func doSomething(num int) (sum int) {
 for i := 1; i <= 10; i++ {
 fmt.Printf("%d + %d = %d\n", num, num + i, num + num + i)
 sum = sum + num + i
 }
 return sum
}
func testLoop() {
 // 建立计数器,通道大小为cpu核数
 var NumCPU = runtime.NumCPU()
 fmt.Printf("NumCPU = %d\n", NumCPU)
 sem :=make(chan int, NumCPU);
 //FOR循环体
 data := []int{1, 11, 21, 31, 41, 51, 61, 71, 81, 91}
 for _,v:= range data {
 //建立协程
 go func (v int) {
 fmt.Printf("doSomething(%d)...\n", v)
 sum := doSomething(v);
 //计数
 sem <- sum;
 } (v);
 }
 // 等待循环结束
 var total int = 0
 for i := 0; i < len(data); i++ {
 temp := <- sem
 fmt.Printf("%d <- sem\n", temp)
 total = total + temp
 }
 fmt.Printf("total = %d\n", total)
}
func main() {
 testLoop()
}

// Send the sequence 2, 3, 4, ... to channel 'in'.
func Generate(ch chan int) {
 for i := 2; ; i++ {
 ch<- i // Send 'i' to channel 'in'.
 }
}
// Copy the values from channel 'in' to channel 'out',
// removing those divisible by 'prime'.
func Filter(in chan int, out chan int, prime int) {
 for {
 i := <-in // Receive valuefrom 'in'.
 if i%prime != 0 {
 out <- i // Send'i' to 'out'.
 }
 }
}
func main() {
 in := make(chan int)
 go Generate(in) // Launch Generate goroutine.
 for i := 0; i < 100; i++ {
 prime := <-in
 print(prime, "\n")
 out := make(chan int)
 go Filter(in, out, prime)
 in = out
 }
}

//共享变量有一个读通道和一个写通道组成
type shardedVar struct {
 reader chan int
 writer chan int
}
//共享变量维护协程
func whachdog(v shardedVar) {
 go func() {
 //初始值
 var value int = 0
 for {
 //监听读写通道,完成服务
 select {
 case value = <-v.writer:
 case v.reader <-value:
 }
 }
 }()
}
func main() {
 //初始化,并开始维护协程
 v := shardedVar{make(chan int), make(chan int)}
 whachdog(v)
 //读取初始值
 fmt.Println(<-v.reader)
 //写入一个值
 v.writer <- 1
 //读取新写入的值
 fmt.Println(<-v.reader)
}

有疑问加站长微信联系(非本文作者)

• 请尽量让自己的回复能够对别人有帮助
• 支持 Markdown 格式, **粗体**、~~删除线~~、`单行代码`
• 支持 @ 本站用户;支持表情(输入 : 提示),见 Emoji cheat sheet
• 图片支持拖拽、截图粘贴等方式上传