内容简介:goroutine实现并发编程,goroutine之间通信使用channel,channel不管是发送数据还是接收数据都是阻塞的,channel默认无缓冲,但也可以指定缓冲大小变成有缓冲,空间有剩余时是无阻塞,直到空间全部用完时才阻塞。
goroutine实现并发编程,goroutine之间通信使用channel,channel不管是发送数据还是接收数据都是阻塞的,channel默认无缓冲,但也可以指定缓冲大小变成有缓冲,空间有剩余时是无阻塞,直到空间全部用完时才阻塞。
/** * goroutine实现并发编程 * goroutine之间通信使用channel * channel不管是发送数据还是接收数据都是阻塞的 * channel默认无缓冲,但也可以指定缓冲大小变成有缓冲,空间有剩余时是无阻塞,直到空间全部用完时才阻塞 */ package main import ( "fmt" ) func sum(a []int, c chan int) { total := 0 for _, v := range a { total += v } // 发送total到c c <- total } func fibonacci(n int, c chan int) { x, y := 1, 1 for i := 0; i < n; i++ { // 发送x到c c <- x x, y = y, x+y } // 通过内置函数close关闭channel close(c) } func main() { a := []int{9, 2, 6, -5, 3, 0} // 使用make创建channel,默认无缓冲,阻塞 c := make(chan int) // 使用 go 关键字启动goroutine go sum(a[:len(a)], c) go sum(a[len(a)/2:], c) // 从c中接收数据 x, y := <-c, <-c fmt.Println(x, y, x+y) // 使用make创建有缓冲的channel,空间有剩余时是无阻塞,直到空间全部用完时才阻塞 // 修改2为1则报错,修改2为3则正常 c1 := make(chan int, 2) c1 <- 1 c1 <- 2 fmt.Println(<-c1) fmt.Println(<-c1) c2 := make(chan int, 10) // 使用go关键字启动goroutine go fibonacci(cap(c2), c2) // 使用range读取channel for i := range c2 { fmt.Println(i) } }
以上就是本文的全部内容,希望本文的内容对大家的学习或者工作能带来一定的帮助,也希望大家多多支持 码农网
猜你喜欢:- sqltoy-orm-4.17.6 发版,支持 Greenplum、并行查询可设置并行数量
- PostgreSQL并行查询介绍
- nodejs“并行”处理尝试
- 并行python迭代
- Golang 多核并行
- haskell – 有效的并行策略
本站部分资源来源于网络,本站转载出于传递更多信息之目的,版权归原作者或者来源机构所有,如转载稿涉及版权问题,请联系我们。
An Introduction to Probability Theory and Its Applications
William Feller / Wiley / 1991-1-1 / USD 120.00
Major changes in this edition include the substitution of probabilistic arguments for combinatorial artifices, and the addition of new sections on branching processes, Markov chains, and the De Moivre......一起来看看 《An Introduction to Probability Theory and Its Applications》 这本书的介绍吧!
HTML 编码/解码
HTML 编码/解码
UNIX 时间戳转换
UNIX 时间戳转换