Golang 并发concurrency

skymyyang · · 1509 次点击 · · 开始浏览    
这是一个创建于 的文章,其中的信息可能已经有所发展或是发生改变。

并发concurrency

  • 很多人都是冲着Go大肆宣扬的高并发而忍不住跃跃欲试,但其实从源码解析来看,goroutine只是由官方实现的超级“线程池”而已。不过话说回来,每个实例4-5KB的栈内存占用和由于实现机制而大幅减少的创建和销毁开销,是制造Go号称的高并发的根本原因。另外goroutine的简单易用,也在语言层面上给予了开发者的巨大的便利。
    并发不是并行 Concurrency Is Not Parallelism
  • 并发主要由切换时间片来实现“同时”运行,在并行则是直接利用多核实现多线程的运行,但Go可以设置使用核数,以发挥多核计算机的能力
  • Goroutine 奉行通过通信来共享内存,而不是共享内存来通信。

Channel

  • Channel 是 goroutine 沟通的桥梁,大都是阻塞同步的
  • 通过 make 创建,close 关闭
  • Channel 是引用类型
  • 可以使用 for range 来迭代不断操作 channel
  • 可以设置单向或双向通道
  • 可以设置缓存大小,在未被填满前不会发生阻塞

通过 make 创建,close 关闭

package main

import (
    "fmt"
)

func main() {
    c := make(chan bool) //声明一个channel
    go func() {
        fmt.Println("GOOD---")
        c <- true //存入这个channel
    }()
    <-c //取出这个channel
    //当这个main函数执行的时候,遇到gorouting时会直接执行到<-c,此时这个程序会阻塞,一直等到有true存入这个channel(c<-true),此时(<-c)才能读出来,main函数完成
}

可以使用 for range 来迭代不断操作 channel

package main

import (
    "fmt"
)

func main() {
    c := make(chan bool)
    go func() {
        fmt.Println("GOOD---")
        c <- true
        close(c) //关闭这个channel,迭代操作会终止
    }()
    for v := range c {
        fmt.Println(v)
    }
}

可以设置缓存大小,在未被填满前是异步的,不会发生阻塞

package main

import (
    "fmt"
    "runtime"
)

func main() {
    runtime.GOMAXPROCS(runtime.NumCPU()) //1.8默认使用多核CPU
    c := make(chan bool, 10)
    for i := 0; i < 10; i++ {
        go Go(c, i)
    }
    for i := 0; i < 10; i++ {
        <-c
    }

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

}

/*
如果设置了缓存大小,大小在未被填满之前,它是异步的,不会发生阻塞
如果这个channel没有缓存的话,要注意取出的操作要在写入的操作的前面
*/
package main

import (
    "fmt"
    "runtime"
    "sync"
)

func main() {
    runtime.GOMAXPROCS(runtime.NumCPU()) //1.8默认使用多核CPU
    wg := sync.WaitGroup{}
    wg.Add(10)
    for i := 0; i < 10; i++ {
        go Go(&wg, i)
    }
    wg.Wait() //通过同步包来实现多个gorouting同步内容

}
func Go(wg *sync.WaitGroup, index int) {
    a := 1
    for i := 0; i < 1000000; i++ {
        a += i
    }
    fmt.Println(index, a)
    wg.Done()

}

/*
如果设置了缓存大小,大小在未被填满之前,它是异步的,不会发生阻塞
如果这个channel没有缓存的话,要注意取出的操作要在写入的操作的前面
*/

Select

  • 可处理一个或多个 channel 的发送与接收
  • 同时有多个可用的 channel时按随机顺序处理
  • 可用空的 select 来阻塞 main 函数
  • 可设置超时
package main

import (
    "fmt"
)

func main() {
    c1, c2 := make(chan int), make(chan string)
    o := make(chan bool)
    go func() {
        for {
            select {
            case v, ok := <-c1:
                if !ok {
                    o <- true
                    break
                }
                fmt.Println("c1", v)
            case v, ok := <-c2:
                if !ok {
                    o <- true
                    break
                }
                fmt.Println("c2", v)
            }
        }
    }()
    c1 <- 1
    c2 <- "hi"
    c1 <- 3
    c2 <- "hello"
    close(c1)
    close(c2)
    <-o
}

select设置超时

package main

import (
    "fmt"
    "time"
)

func main() {
    c := make(chan bool)
    select {
    case v := <-c:
        fmt.Println(v)
    case <-time.After(3 * time.Second): //返回的是一个time类型的chan
        fmt.Println("TimeOut")
    }
}

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

本文来自:博客园

感谢作者:skymyyang

查看原文:Golang 并发concurrency

入群交流(和以上内容无关):加入Go大咖交流群,或添加微信:liuxiaoyan-s 备注:入群;或加QQ群:692541889

1509 次点击  
加入收藏 微博
暂无回复
添加一条新回复 (您需要 登录 后才能回复 没有账号 ?)
  • 请尽量让自己的回复能够对别人有帮助
  • 支持 Markdown 格式, **粗体**、~~删除线~~、`单行代码`
  • 支持 @ 本站用户;支持表情(输入 : 提示),见 Emoji cheat sheet
  • 图片支持拖拽、截图粘贴等方式上传