??斗地主捕鱼电竞提现秒到 广告位招租 - 15元/月全站展示
??支付宝搜索579087183领大额红包 ??伍彩集团官网直营彩票
??好待遇→招代理 ??伍彩集团官网直营彩票
??络茄网 广告位招租 - 15元/月全站展示
go语言并发编程

转载   PowerMichael   2018-11-14   浏览量:19


一、goroutine

与传统的系统级线程和进程相比,协程的大优势在于其“轻量级”,可以轻松创建上百万个而不会导致系统资源衰竭,而线程和进程通常多也不能超过1万个。这也是协程也叫轻量级线程的原因。
golang原生支持并发编程
轻量级线程
非抢占式多任务处理,由协程主动交出控制权
编译器/解释器/虚拟机层面的多任务
多个协程可能在一个或多个线程上运行

go语言并发编程


1.1 go对协程的实现

goroutine--Go对协程的实现
go + 函数名:启动一个协程执行函数体

package main

import (
    "fmt"
    "time"
)

func test_Routine() {
    fmt.Println("This is one routine!!!")
}

func Add(x, y int) {
    z := x + y
    fmt.Println(z)
}

func main() {
    for i := 1; i < 10; i++ {
        //启动一个协程执行函数体
        go Add(i, i)
    }

    //为避免并发执行后程序立即退出,先sleep 2秒
    time.Sleep(2)
}

package main

import (
    "fmt"
    "runtime"
    "time"
)

func main() {
    //定义一个数组
    var a [10]int
    //循环并发执行匿名函数,实现
    for i := 0; i < 10; i ++ {
        go func(i int) {
            for {
                a[i]++
                //主动让go协程让出时间片
                runtime.Gosched()
            }
        }(i)
    }
    time.Sleep(time.Millisecond)
    fmt.Println(a)
}

二、channel

Go语言在语言级别提供的goroutine间的通信方式
不要通过共享来通信,而要通过通信来共享。
channel的读写默认是阻塞的,除非有goroutine对其进行操作。

go语言并发编程

package main

import (
    "fmt"
    "strconv"
)

//定义一个加法函数,传入x,y整型参数,quit整型通道
func Add(x, y int, quit chan int) {
    z := x + y
    fmt.Println(z)

    //发送 1 到channel quit
    quit <- 1
}

//读取channel中的数据
func Read(ch chan int) {
    //将channel中数据发送出去,赋值给value
    value := <-ch

    fmt.Println("value:" + strconv.Itoa(value))
}

//写数据到channel中
func Write(ch chan int) {
    //ch <- 10
}

func main() {
    //ch := make(chan int)
    //go Read(ch)
    //go Write(ch)

    //time.Sleep(10)

    //fmt.Println("end of code")

    //定义一个容量为10的非阻塞整型通道切片,变 量名为chs
    chs := make([]chan int, 10)
    //循环地给channel切片chs初始化
    for i := 0; i < 10; i++ {
        chs[i] = make(chan int)
        go Add(i, i, chs[i])
    }

    //遍历channel切片chs,并从channel中发出数据,留空
    for _, v := range chs {
        <-v
    }
}

三、缓冲channel

定义: c = make(chan int, n) n为缓冲区的大小,代表channel可以存储多少个元素,这几个元素可以无阻塞的写入,缓存的元素写满之后阻塞,除非有goroutine操作。


例子中定义一个容量为2的channel,


// 缓冲channel
package main

import (
    "fmt"
    "time"
)

// 定义一个chnnel类型变量 ch
var ch chan int

//测试buffered channel函数
func test_channel() {
    // 第一次发送常量1到channel ch
    ch <- 1
    fmt.Println("ch 1")
    // 第二次发送常量1到channel ch
    ch <- 1
    fmt.Println("ch 2")
    // 第三次发送常量1到channel ch
    ch <- 1
    fmt.Println("come to end goroutine 1")
}

func main() {
    ch = make(chan int, 0) // 等价于 ch = make(chan int) 都是不带缓冲的channel
    ch = make(chan int, 2) // 是带缓冲的channel
    go test_channel()
    time.Sleep(2 * time.Second)
    fmt.Println("running end!")
    <-ch

    time.Sleep(time.Second)
}

output:
ch 1
ch 2
running end!
come to end goroutine 1

package main

import "fmt"

func main() {
    c := make(chan int, 3   )//修改2为1就报错,修改2为3可以正常运行
    c <- 1
    c <- 2
    fmt.Println(<-c)
    fmt.Println(<-c)
}

四、select

Linux很早就引入的函数,用来实现非阻塞的一种方式。Go语言直接在语言级别支持select关键字,用于处理异步IO 问题。我们上面介绍的都是只有一个channel的情况,那么如果存在多个channel的时候,我们该如何操作呢,Go里面提供了一个关键字select,通过select可以监听channel上的数据流动。
select默认是阻塞的,只有当监听的channel中有发送或接收可以进行时才会运行,当多个channel都准备好的时候,select是随机的选择一个执行的。

package main

import (
    "fmt"
    "time"
)

func main() {
    ch := make(chan int)

    //匿名函数,传入一个参数整型channel类型ch
    go func(ch chan int) {
        ch <- 1
    }(ch)

    time.Sleep(time.Second)

    select {
    //如果ch成功读到数据,则执行下面的语句
    case <-ch:
        fmt.Print("come to read ch!")
    default:
        fmt.Print("come to default!")
    }
}

// 实现超时控制
package main

import (
    "fmt"
    "time"
)

func main() {
    ch := make(chan int)
    //定义一个channel timeout
    timeout := make(chan int, 1)

    //定义一个匿名函数,用来实现超时控制
    go func() {
        time.Sleep( time.Second)
        timeout <- 1
    }()

    select {
    case <-ch:
        fmt.Print("come to read ch!\n")
    case <-timeout:
        fmt.Print("come to timeout!\n")
    }

    fmt.Print("end of code!")
}

// 使用time.After(time.Second)实现控制
package main

import (
    "fmt"
    "time"
)

func main() {
    ch := make(chan int)

    select {
    case <-ch:
        fmt.Print("come to read ch!\n")
    case <-time.After(time.Second):
        fmt.Print("come to timeout!\n")
    }

    fmt.Print("end of code!")
}

// goroutine_2.go
package main

import (
    "fmt"
    "runtime"
    "strconv"
    "time"
)

func main() {
    //协程1
    go func() {
        for i := 1; i < 100; i++ {
            if i == 10 {
                //主动出让cpu 使用的话 需要 导入 runtime包
                runtime.Gosched()
            }
            fmt.Println("routine 1:" + strconv.Itoa(i))
        }
    }()

    //协程2
    go func() {
        for i := 100; i < 200; i++ {
            fmt.Println("routine 2:" + strconv.Itoa(i))
        }
    }()

    time.Sleep(time.Second)
}

转载自://blog.51cto.com/huwho/2316679

招聘 不方便扫码就复制添加关注:程序员招聘谷,微信号:jobs1024


上一篇:

使用Go来模拟Java中的接口 实现类
针对项目中,相同的流程业务进行重构,使用Go来简单模拟Java中的接口,实现类的方式进行重构。分享一简单例子:packagemain//模拟java中的接口,实现类import"fmt"//声明一个接口,typeworkthreadinterface{do(namestring)}//传入的wt的子类不同,do方法执行的逻辑也不同funcHandle(wtworkthread,namestring
md5加密算法原理及其GO语言实现
md5加密算法原理及其GO语言实现MD5讯息摘要演算法(英语:MD5Message-DigestAlgorithm),一种被广泛使用的密码杂凑函数,可以产生出一个128位元(16位元组)的散列值(hashvalue),用于确保信息传输完整一致。go调用md5方法新建md5.go文件,代码如下:packagemainimport(&quot;fmt&quot;...
Go语言中时间函数及定时器的使用
Go语言中时间函数的使用,定时器的实现
各种加密算法在Go语言中的使用
实际编程过程经?;嵊龅绞褂酶髦旨用芩惴?,本文以代码详细介绍了在Go语言中如何使用MD5、SHA256、RIPEMD160、DES、3DES、AES进行加密
Go语言之如何给*int32类型赋值
直接上代码:packagemainimport"fmt"funcmain(){varnum*int32variint32=5//针对*int32的,先创建一个i类型,然后取i的地址,赋值给*int32num=&ifmt.Println("=====>:\t",num)fmt.Println("=====>:\t",*num)}运行结果:=====>:0xc04206408
go语言学习之路(二)——go语言进行微信公众号开发
学习教程地址://www.imooc.com/topic/golang?mc_marking=ed9ea9bd605fe0066c71d80cc8603806&amp;amp;mc_channel=bdgoyyzt&amp;amp;audience=230227github地址:https://github.com/leeeboo/leeeboo.github.com微信公众号开发文档:https://...
golang并发ssh执行远程命令实现教程
golang并发ssh执行远程命令实现教程。在kubernetesdocker容器化应用中,业务应用由大量容器组成,由于生产环境中出于安全考虑,一般不会允许用户直接登入集群机器,然后登入机器上的容器。
Go语言之读取yaml配置文件,转换成struct结构,json形式输出
1、例子11.1、yaml文件内容如下:host:localhost:3306user:rootpwd:123456dbname:test1.2、代码如下://将yaml文件,转换成对象,再转换成json格式输出packagemainimport("encoding/json""fmt""gopkg.in/yaml.v2""io/ioutil")//定义conf类型//类型里的属性,全是配置文件里
Go语言之正则表达式
[TOC]Go语言正则表达式方式一:使用Compilepackagemainimport("fmt""regexp")consttext="[email protected]"funcmain(){//re是正则表达式的匹配器re,err:=regexp.Compile("[email protected]")iferr!=nil{panic(err)}r
Go语言中日志处理,log包的使用
Golang提供了原生日志库“log”,使用简单方便,本文以代码为例进行说明介绍。