go语言并发操作

go语言实现并发

通过go 实现并发操作

func say(s string) {
for i := 0; i < 5; i++ {
    fmt.Println(s)
}
}

func main(){
    go say("hello")
    say("world")
}

执行上述代码，会间隔执行say方法

通过channel实现并发数据间的通信

channel的创建必须通过make方式实现

ch := make(chan int)

channel通过操作符<-接收和发送数据

ch <- value //发送value到channel ch
value := <-ch //从channel ch中获取数据

下面开始是此节的重点内容，废话不多说先上代码

代码1：
func sum(a []int, c chan int) {
    fmt.Println("开始往channel中写数据", a)
    total := 0
    for _, v := range a {
        total += v
    }
    c <- total
    fmt.Println("单次写数据处理完成")
}

func main() {
    a := []int{1, 2, 3, 4}

    c := make(chan int)
    fmt.Println("write")
    sum(a[:len(a)/2], c)
    sum(a[len(a)/2:], c)
    fmt.Println("write end")
}
控制台输出：
write
开始往channel中写数据 [1 2]
单次写数据处理完成
开始往channel中写数据 [3 4]
fatal error: all goroutines are asleep - deadlock!

程序出现错误，因为我们创建一个未指定缓冲大小的channel(当未指定缓冲大小时，channel默认为0)，
我们调用两次channel的写操作，出现了阻塞

代码2：
func sum(a []int, c chan int) {
    fmt.Println("开始往channel中写数据", a)
    total := 0
    for _, v := range a {
        total += v
    }
    fmt.Println("单次写数据处理完成")
    c <- total
}

func main() {
    a := []int{1, 2, 3, 4}

    c := make(chan int, 2)//这里我们指定channel的缓冲为2
    fmt.Println("write")
    sum(a[:len(a)/2], c)
    sum(a[len(a)/2:], c)
    fmt.Println("write end")
}
控制台输出：
write
开始往channel中写数据 [1 2]
单次写数据处理完成
开始往channel中写数据 [3 4]
单次写数据处理完成
write end

程序正常结束，因为我们指定了channel的缓冲大小，所以可以进行两次写操作

代码3：
func sum(a []int, c chan int) {
    fmt.Println("开始往channel中写数据", a)
    total := 0
    for _, v := range a {
        total += v
    }
    fmt.Println("单次写数据处理完成")
    c <- total
}

func main() {
    a := []int{1, 2, 3, 4}

    c := make(chan int)//如果我们不指定channel的缓冲大小如何实现两次写操作呢
    fmt.Println("write")
    go sum(a[:len(a)/2], c)
    go sum(a[len(a)/2:], c)
    fmt.Println("write end")

}
控制台输出：
write
write end

程序正常结束，这是因为我们使用并发调用调用sum方法

代码4：
var (
      wg sync.WaitGroup
)
func sum(a []int, c chan int) {
    fmt.Println("开始往channel中写数据", a)
    total := 0
    for _, v := range a {
        total += v
    }
    fmt.Println("单次写数据处理完成")
    c <- total
        wg.Done()
}

func main() {
        wg.Add(2)
    a := []int{1, 2, 3, 4}

    c := make(chan int)
    fmt.Println("write")
    go sum(a[:len(a)/2], c)
    go sum(a[len(a)/2:], c)
    fmt.Println("write end")
        wg.Wait()
}
控制台输出：
fatal error: all goroutines are asleep - deadlock!
write
write end

程序异常，我们在主线程采用WaitGroup保持主线程不被销毁，这样异步线程就有时间进行处理，造成chan阻塞，代码4未发生阻塞，是因为主线程立刻就结束

代码5：
func sum(a []int, c chan int) {
    fmt.Println("开始往channel中写数据", a)
    total := 0
    for _, v := range a {
        total += v
    }
    fmt.Println("单次写数据处理完成")
    c <- total
}

func main() {
    a := []int{1, 2, 3, 4}

    c := make(chan int,1)//我们指定channel的缓冲大小为1，但是我们调用两次写操作，其中一次为并发调用
    fmt.Println("write")
    go sum(a[:len(a)/2], c)
    sum(a[len(a)/2:], c)
    fmt.Println("write end")
    fmt.Println("read x")
    x := <-c
    fmt.Println("x = ", x)
    fmt.Println("read Y")
    y := <-c
    fmt.Println("y = ", y)
    fmt.Println("read end")
}
控制台输出：
write
开始往channel中写数据 [3 4]
单次写数据处理完成
write end
read x
x =  7
read Y
开始往channel中写数据 [1 2]
单次写数据处理完成
y =  3
read end

程序正常结束，可以看到首先执行了main线程调用的sum方法，
然后进行一次x值的读取，取得的为main线程写入的数据，
再进行一次y值的读取，先进行了数据的写入，然后返回写入的值

代码6：
func sum(a []int, c chan int) {
    fmt.Println("开始往channel中写数据", a)
    total := 0
    for _, v := range a {
        total += v
    }
    fmt.Println("单次写数据处理完成")
    c <- total
}

func main() {
    a := []int{1, 2, 3, 4}

    c := make(chan int,2)//我们指定channel的缓冲大小为2
    fmt.Println("write")
    sum(a[:len(a)/2], c)
    sum(a[len(a)/2:], c)
    fmt.Println("write end")
    fmt.Println("read x")
    x := <-c
    fmt.Println("x = ", x)
    fmt.Println("read Y")
    y := <-c
    fmt.Println("y = ", y)
    fmt.Println("read end")
}
控制台输出：
write
开始往channel中写数据 [1 2]
单次写数据处理完成
开始往channel中写数据 [3 4]
单次写数据处理完成
write end
read x
x =  3
read Y
y =  7
read end

程序正常结束，可以看到首先执行两次main线程调用的sum方法，然后分别x,y获取两次写入的值

代码7：
func sum(a []int, c chan int) {
    fmt.Println("开始往channel中写数据", a)
    total := 0
    for _, v := range a {
        total += v
    }
    fmt.Println("单次写数据处理完成")
    c <- total
}

func main() {
    a := []int{1, 2, 3, 4}

    c := make(chan int)//我们未指定channel的缓冲大小
    fmt.Println("write")
    go sum(a[:len(a)/2], c)
    go sum(a[len(a)/2:], c)
    fmt.Println("write end")
    fmt.Println("read x")
    x := <-c
    fmt.Println("x = ", x)
    fmt.Println("read Y")
    y := <-c
    fmt.Println("y = ", y)
    fmt.Println("read end")
}
控制台输出：
write
write end
read x
开始往channel中写数据 [3 4]
单次写数据处理完成
x =  7
read Y
开始往channel中写数据 [1 2]
单次写数据处理完成
y =  3
read end

程序正常结束，可以看到我们异步调用两次sum方法，
然后main线程获取x值，输入第二次异步的日志，同时返回写入的数据，
获取y值，输入第一次异步的日志，同时返回写入的数据

通过range获取channel数据

range获取channel的数据跟普通的<-唯一的区别在于需要显形的关闭channel

close(ch)

废话不多说继续上代码

代码1：
func fibonacci(n int, c chan int) {
    x, y := 1, 1
    fmt.Println("开始往channel中写数据", n)
    for i := 0; i < n; i++ {
        c <- x
        x, y = y, x+y
    }
    fmt.Println("单次写数据处理完成")
}

func main() {
    ch2 := make(chan int)
    fmt.Println("开始range的写操作")
    go fibonacci(10, ch2)
    fmt.Println("写操作结束")
    fmt.Println("开始range的读操作")
    for i := range ch2 {
        fmt.Println(i)
    }
    fmt.Println("读操作结束")
}
控制台输出：
fatal error: all goroutines are asleep - deadlock!

goroutine 1 [chan receive]:
main.main()
    /Users/cheyongzi/Desktop/data/project/GoDemo/routine/runtime.go:66 +0x242
开始range的写操作
写操作结束
开始range的读操作
开始接收
1
1
2
3
5
8
13
21
34
55

程序异常退出，这是因为range获取channel的数据需要显性的调用close方法关闭channel

代码1：
func fibonacci(n int, c chan int) {
    x, y := 1, 1
    fmt.Println("开始往channel中写数据", n)
    for i := 0; i < n; i++ {
        c <- x
        x, y = y, x+y
    }
    close(c)
    fmt.Println("单次写数据处理完成")
}

func main() {
    ch2 := make(chan int)
    fmt.Println("开始range的写操作")
    go fibonacci(10, ch2)//这里如果不采用异步调用，则需要在ch2定义的时候指定缓冲大小，否则会报错
    fmt.Println("写操作结束")
    fmt.Println("开始range的读操作")
    for i := range ch2 {
        fmt.Println(i)
    }
    fmt.Println("读操作结束")
}
控制台输出：
开始range的写操作
写操作结束
开始range的读操作
开始接收
1
1
2
3
5
8
13
21
34
55
读操作结束

程序正常运行

最后编辑于：2017.12.10 06:30:26

人面猴
序言：七十年代末，一起剥皮案震惊了整个滨河市，随后出现的几起案子，更是在滨河造成了极大的恐慌，老刑警刘岩，带你破解...
沈念sama阅读 203,098评论 5赞 476
死咒
序言：滨河连续发生了三起死亡事件，死亡现场离奇诡异，居然都是意外死亡，警方通过查阅死者的电脑和手机，发现死者居然都...
沈念sama阅读 85,213评论 2赞 380
救了他两次的神仙让他今天三更去死
文/潘晓璐我一进店门，熙熙楼的掌柜王于贵愁眉苦脸地迎上来，“玉大人，你说我怎么就摊上这事。” “怎么了？”我有些...
开封第一讲书人阅读 149,960评论 0赞 336
道士缉凶录：失踪的卖姜人
文/不坏的土叔我叫张陵，是天一观的道长。经常有香客问我，道长，这世上最难降的妖魔是什么？我笑而不...
开封第一讲书人阅读 54,519评论 1赞 273
港岛之恋（遗憾婚礼）
正文为了忘掉前任，我火速办了婚礼，结果婚礼上，老公的妹妹穿的比我还像新娘。我一直安慰自己，他们只是感情好，可当我...
茶点故事阅读 63,512评论 5赞 364
恶毒庶女顶嫁案：这布局不是一般人想出来的
文/花漫我一把揭开白布。她就那样静静地躺着，像睡着了一般。火红的嫁衣衬着肌肤如雪。梳的纹丝不乱的头发上，一...
开封第一讲书人阅读 48,533评论 1赞 281
城市分裂传说
那天，我揣着相机与录音，去河边找鬼。笑死，一个胖子当着我的面吹牛，可吹牛的内容都是我干的。我是一名探鬼主播，决...
沈念sama阅读 37,914评论 3赞 395
双鸳鸯连环套：你想象不到人心有多黑
文/苍兰香墨我猛地睁开眼，长吁一口气：“原来是场噩梦啊……” “哼！你这毒妇竟也来了？” 一声冷哼从身侧响起，我...
开封第一讲书人阅读 36,574评论 0赞 256
万荣杀人案实录
序言：老挝万荣一对情侣失踪，失踪者是张志新（化名）和其女友刘颖，没想到半个月后，有当地人在树林里发现了一具尸体，经...
沈念sama阅读 40,804评论 1赞 296
护林员之死
正文独居荒郊野岭守林人离奇死亡，尸身上长有42处带血的脓包…… 初始之章·张勋以下内容为张勋视角年9月15日...
茶点故事阅读 35,563评论 2赞 319
白月光启示录
正文我和宋清朗相恋三年，在试婚纱的时候发现自己被绿了。大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
茶点故事阅读 37,644评论 1赞 329
活死人
序言：一个原本活蹦乱跳的男人离奇死亡，死状恐怖，灵堂内的尸体忽然破棺而出，到底是诈尸还是另有隐情，我是刑警宁泽，带...
沈念sama阅读 33,350评论 4赞 318
日本核电站爆炸内幕
正文年R本政府宣布，位于F岛的核电站，受9级特大地震影响，放射性物质发生泄漏。R本人自食恶果不足惜，却给世界环境...
茶点故事阅读 38,933评论 3赞 307
男人毒药：我在死后第九天来索命
文/蒙蒙一、第九天我趴在偏房一处隐蔽的房顶上张望。院中可真热闹，春花似锦、人声如沸。这庄子的主人今日做“春日...
开封第一讲书人阅读 29,908评论 0赞 19
一桩弑父案，背后竟有这般阴谋
文/苍兰香墨我抬头看了看天上的太阳。三九已至，却和暖如春，着一层夹袄步出监牢的瞬间，已是汗流浃背。一阵脚步声响...
开封第一讲书人阅读 31,146评论 1赞 259
情欲美人皮
我被黑心中介骗来泰国打工，没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留，地道东北人。一个月前我还...
沈念sama阅读 42,847评论 2赞 349
代替公主和亲
正文我出身青楼，却偏偏与公主长得像，于是被迫代替她去往敌国和亲。传闻我的和亲对象是个残疾皇子，可洞房花烛夜当晚...
茶点故事阅读 42,361评论 2赞 342

go语言并发操作

go语言实现并发

通过go 实现并发操作

通过channel实现并发数据间的通信

通过range获取channel数据

推荐阅读更多精彩内容