详解go语言的并发
1、启动go语言的协程
package main
import (
"fmt"
"runtime"
)
//runtime包
func main() {
//runtime.Gosched() 用于让出cpu时间片，让出这段cpu的时间片，让调度器重新分配资源
//写一个匿名函数
s := "test"
go func(s string) {
for i :=0;i <2;i++ {
fmt.Println(s)
}
}(s)
for i :=0;i <2;i ++ {
//如果代码跑到这里，调度器会把cpu资源释放出来，让调度器重新分配cpu资源,可以分配到子协程，也可以重新分配到主协程
runtime.Gosched()
fmt.Println("123")
}
}
2、runtime.Goexit()方法。立即终止当前的协程
package main
import (
"fmt"
"runtime"
"time"
)
//runtime.Goexit() 立即终止当前的协程
func main() {
go func() {
defer fmt.Println("A.defter")
func () {
defer fmt.Println("B.defter")
//立即终止当前的协程，函数会走defer流程
runtime.Goexit()
fmt.Println("B")
}()
fmt.Println("A")
}()
for {
time.Sleep(2 * time.Second)
}
}
//不加runtime.Goexit()的结果
//B
//B.defter
//A
//A.defter
//加runtime.Goexit()的结果
//B.defter
//A.defter
3、runtime.GOMAXPROCS()表示go使用几个cpu执行代码
package main
import (
"fmt"
"runtime"
)
func main() {
//runtime.GOMAXPROCS() 表示让go用几个cpu做后面的事情
n := runtime.GOMAXPROCS(4)
fmt.Printf("%T--->%p---%d\n",n,n,n)
for {
go fmt.Print("0")
fmt.Print(1)
}
}
4、管道定义和创建管道
package main
import "fmt"
//go语言的协程运行在相同的地址空间，因此访问共享内存必须做好同步，处理好线程安全问题
//go语言的协程之间的通信通过协程间通信来共享内存，而不是共享内存来通信
//channel是一个引用类型，用于多个协程间通信，内部实现了同步，确保并发安全
//通道一般是结合协程一起使用
//如果通道中没有数据，后面你还去取数据，则会报错
//fatal error: all goroutines are asleep - deadlock!
func main() {
//test45_1 := make(chan int) //定义一个无缓冲的通道
//无缓冲的通道是值在接受数据前没有任何能力保存数据,只能有一个数据进入通道，进入通道后，该通道就会加锁，一直到这个数据被取出，锁才释放
//无缓冲的通道有可能阻塞，如果我发送一个数据到通道，但是没有协程来取数据，则对于第一个协程就被阻塞
//test45_2 := make(chan int,10) //定义 一个有缓冲的通道
//有缓冲的通道就是通道可以存储指定数量的数据，数据在里面也是有顺序的，但是如果缓冲的数量满了，这个通道也会是阻塞的
//
//test45_1 <- 10 //发送数据到通道
//<- test45_1 //接受通道中的数据，并丢弃
//x := <-test45_1 //从通道取值并赋值给x
//x,ok := <-test45_1 //ok检查通道是否关闭或者是否为空
//1、创建一个存放int类型的通道
test45_1 := make(chan int)
go func() {
defer fmt.Println("子协程结束")
fmt.Println("子协程正在运行")
test45_1 <- 111
}()
//<- test45_1
//主协程从通道中取数据
x := <- test45_1
fmt.Println(x)
fmt.Println("主协程结束")
}
5、管道的缓冲
package main
import (
"fmt"
"time"
)
func main() {
//无缓冲的通道，长度为0就可以了，有缓冲的通道，这里设置为非0就可以了
test46_1 := make(chan int,0)
//%P是打印内存地址，%T是打印变量的类型
//fmt.Printf("长度:%d--->容量:%d---->%P----%T",len(test46_1),cap(test46_1),test46_1,test46_1)
go func() {
defer fmt.Printf("子协程结束")
for i :=0;i < 3;i ++ {
fmt.Println("子协程插入数据")
test46_1 <- i
//fmt.Printf("长度:%d--->容量:%d---->%P----%T",len(test46_1),cap(test46_1),test46_1,test46_1)
}
}()
time.Sleep(2 * time.Second)
for j :=0;j <3;j++ {
fmt.Println("主协程取数据")
num := <- test46_1
fmt.Println(num)
}
}
6、关闭管道和接受关闭管道的信号
package main
import "fmt"
//close（）方法，关闭通道的意思
func main() {
test47_1 := make(chan int,4)
go func() {
for i :=0;i < 10;i ++ {
test47_1 <- i
}
//这个的意思关闭通道test47_1
close(test47_1)
}()
//for的写法,遍历通道
//for {
// //子协程关闭了通道，这里ok就可以接收到，这里就可以走到bread流程,ok这个参数表示通道是否关闭
// if data,ok := <- test47_1;ok {
// fmt.Println(data)
// }else {
// break
// }
//}
//range的写法，遍历通道
for data := range test47_1 {
fmt.Println(data)
}
fmt.Println("主协程结束")
}
7、只读管道和只写管道和生产者和消费者模型
package main
import (
"fmt"
"time"
)
//默认情况下，管道是双向的,既可以写入数据，也可以读出数据。go也可以定义单方向的管道，也就是说只发送数据，或者只写入数据
//可以把双向的管道转换为单向的管道，但是不能把单向的管道转换为双向的管道
//单方向的管道
func producter(out chan <- int) {
defer close(out)
for i := 0;i < 10;i++ {
out <- i
}
}
func consumer(int <-chan int){
for num := range int {
fmt.Println(num)
}
}
func main() {
//1、定义管道
//定义一个正常的管道
//var test48_1 chan int
//定义一个单向的只写的管道
//var test48_2 chan <- float32
//定义一个单向的只读的管道
//var test48_3 <- chan int
//2、转换管道
//转换正常管道为只写或者只读的管道
//定义一个正常的管道
//test48_4 := make(chan int,3)
//把一个正常的管道转换为一个只写的管道
//var write_only chan <- int = test48_4
//把一个正常的管道转换为一个只读的管道
//var read_only <- chan int = test48_4
test48_5 := make(chan int,4)
//启动生产者
go producter(test48_5)
//启动消费者
consumer(test48_5)
time.Sleep(10 * time.Millisecond)
fmt.Println("down")
}
8、Timer定时器
package main
import (
"fmt"
"time"
)
//定时器
//time.NewTimer()。时间到了，只执行一次
//time.NewTicker(),周期性的执行
func main() {
//1、创建一个定时器，2s后定时器会将一个时间保存到一个C
test49_1 := time.NewTimer(2 * time.Second)
//打印系统当前的时间
t1 := time.Now()
fmt.Printf("t1----->%v\n",t1)
//从管道中取出C打印
t2 := <- test49_1.C
fmt.Printf("t2----->%v\n",t2)
//2、证明timer只执行一次
//test49_2 := time.NewTimer(4 * time.Second)
//
//for {
// c := <- test49_2.C
// fmt.Println(c)
//}
//3、通过timer实现一个延时的功能
//方式1
//time.Sleep(2 * time.Second)
//方式2
//test49_3 := time.NewTimer(2 * time.Second)
//方式3
//<-time.After(2 *time.Second)
//4、停止定时器
test49_4 := time.NewTimer(4 * time.Second)
//子协程
go func() {
//这个意思是3s后才能取出来数据
<- test49_4.C
fmt.Println("定时器时间到了")
}()
//关闭定时器
stop := test49_4.Stop()
if stop {
fmt.Println("定时器已经关闭")
}
//5、重置定时器
test49_5 := time.NewTimer(4 * time.Second)
//重置定时器为1s
test49_5.Reset(1 * time.Second)
for {
}
}
9、ticker定时器和关闭ticker定时器
package main
import (
"fmt"
"time"
)
//time.NewTicker()，定时器，响应多次
func main() {
//创建一个定时器，间隔1s
test50_1 := time.NewTicker(time.Second)
i := 0
go func() {
for {
c := <- test50_1.C
fmt.Println(c)
i ++
fmt.Println(i)
}
}()
for {
}
}
10、select语句
package main
import (
"fmt"
)
//go语言提供select关键字，用来监听通道上的数据流动，语法和switch类似,区别是select必须要求每个case语句里必须是一个IO操作
//如果都能匹配到，则随机选择一个通道去跑，select是比较随便的
func main() {
//test51_1 := make(chan int,3)
//select {
//case <- test51_1:
// fmt.Println("jja")
////如果从通道中可以读出数据，则执行这里
//case test51_1 <- 1:
// fmt.Println("aa")
////如果通道中北写入数据，则执行号这里
//default:
// fmt.Println("hah")
////如果上面都没成功，则执行这里
//}
test51_1 := make(chan int,1)
test51_2 := make(chan string,1)
go func() {
//time.Sleep(2 * time.Second)
test51_1 <- 1
}()
go func() {
test51_2 <- "Hello World"
}()
select {
case Value1:= <- test51_1:
fmt.Println(Value1)
case Value2 := <- test51_2:
fmt.Println(Value2)
}
fmt.Println("结束")
}
11、协程同步锁
package main
import (
"fmt"
"sync"
"time"
)
//go语言的协程同步锁，解决并发安全问题
//取钱的例子
type Account struct {
money int
flag sync.Mutex
}
func Check(a *Account) {
time.Sleep(1 * time.Second)
}
func (a *Account)SetAccount(n int) {
a.money = n
}
func (a *Account)GetAccount() (n int) {
return a.money
}
func (a *Account) buy1(n int) {
a.flag.Lock()
if a.money > n {
Check(a)
a.money -= n
}
a.flag.Unlock()
fmt.Println(a.money)
}
func (a *Account) buy2(n int) {
a.flag.Lock()
if a.money > n {
Check(a)
a.money -= n
}
a.flag.Unlock()
fmt.Println(a.money)
}
func main() {
var test52_1 Account
test52_1.SetAccount(10)
go test52_1.buy1(5)
go test52_1.buy2(6)
for {
}
}
12、wait
我们自己实现wait
package main
import "fmt"
//Add() 计数加1
//Done() 计数减1
//Wait() 主函数调用
func main() {
test53_1 := make(chan int,2)
count := 2
go func() {
fmt.Println("子协程1")
test53_1 <- 1
}()
go func() {
fmt.Println("子协程2")
test53_1 <- 2
}()
for range test53_1 {
count --
if count == 0 {
fmt.Println("所有的子协程都已经结束")
close(test53_1)
}
}
}
go语言为我们实现wait
package main
import (
"fmt"
"sync"
)
//Add() 计数加1
//Done() 计数减1
//Wait() 主函数调用
func main() {
var wait_group sync.WaitGroup
//这里就是子协程的个数
wait_group.Add(2)
//test54_1 := make(chan int,2)
go func() {
fmt.Println("子协程1")
wait_group.Done()
}()
go func() {
fmt.Println("子协程2")
wait_group.Done()
}()
wait_group.Wait()
//close(test53_1)
fmt.Println("所有的子协程都结束")
}
以上就是详解go语言的并发的详细内容，更多关于go语言的并发的资料请关注我们其它相关文章！
相关推荐
-
浅谈golang并发操作变量安全的问题
我就废话不多说了,大家还是直接看代码吧~ package main import ( "fmt" "time" "sync" "sync/atomic" ) func main() { test1() test2() } func test1() { var wg sync.WaitGroup count := 0 t := time.Now() for i := 0 ; i < 50000 ; i++ { wg.Add
-
golang通过context控制并发的应用场景实现
golang 里出现多 goroutine 的场景很常见, 最常用的两种方式就是 WaitGroup 和 Context, 今天我们了解一下 Context 的应用场景 使用场景 场景一: 多goroutine执行超时通知 并发执行的业务中最常见的就是有协程执行超时, 如果不做超时处理就会出现一个僵尸进程, 这累计的多了就会有一阵手忙脚乱了, 所以我们要在源头上就避免它们 看下面这个示例: package main import ( "context" "fmt"
-
Django高并发负载均衡实现原理详解
1 什么是负载均衡? 当一台服务器的性能达到极限时,我们可以使用服务器集群来提高网站的整体性能.那么,在服务器集群中,需要有一台服务器充当调度者的角色,用户的所有请求都会首先由它接收,调度者再根据每台服务器的负载情况将请求分配给某一台后端服务器去处理. 那么在这个过程中,调度者如何合理分配任务,保证所有后端服务器都将性能充分发挥,从而保持服务器集群的整体性能最优,这就是负载均衡问题. 下面详细介绍负载均衡的四种实现方式 2 HTTP重定向实现负载均衡 过程描述 当用户向服务器发起请求时,请求首先
-
一百行Golang代码实现简单并发聊天室
项目介绍:Golang100行代码实现高并发聊天室,其中实现的功能有:上下线广播,私聊,用户改名,超时强踢,在线用户检测等 在开始项目前,我们需要理解贯穿这整个项目的两个重要变量,若能理解这两个变量的使用,那么并发聊天室项目会变得手到擒来.第一个是onlinemap全局map,第二个是Message全局channel. 取名为onlinemap的全局map类型为map[string][client],这个全局字典是用来存储当前在此聊天室的用户的,key值是string类型,为用户的ip地址+Po
-
Golang 实现分片读取http超大文件流和并发控制
分片读取http超大文件流 Golang中的HTTP发送get请求,在获取内容有两种情况. Golang发送http get请求方式 resp, err := http.Get(sendUrl) if err != nil { fmt.Println("出错", err) return } 第一种方式是直接全部读取出来,这种方式在小数据量的时候很方便. body变量直接全部接收resp响应内容 body, err2 := ioutil.ReadAll(resp.Body) 第二种方式,
-
快速解决Golang Map 并发读写安全的问题
一.错误案例 package main import ( "fmt" "time" ) var TestMap map[string]string func init() { TestMap = make(map[string]string, 1) } func main() { for i := 0; i < 1000; i++ { go Write("aaa") go Read("aaa") go Write(&qu
-
详解Go多协程并发环境下的错误处理
引言 在Go语言中,我们通常会用到panic和recover来抛出错误和捕获错误,这一对操作在单协程环境下我们正常用就好了,并不会踩到什么坑.但是在多协程并发环境下,我们常常会碰到以下两个问题.假设我们现在有2个协程,我们叫它们协程A和B好了: 如果协程A发生了panic,协程B是否会因为协程A的panic而挂掉? 如果协程A发生了panic,协程B是否能用recover捕获到协程A的panic? 答案分别是:会.不能. 那么下面我们来一一验证,并给出在具体的业务场景下的最佳实践. 问题一 如果
-
基于Django的乐观锁与悲观锁解决订单并发问题详解
前言 订单并发这个问题我想大家都是有一定认识的,这里我说一下我的一些浅见,我会尽可能的让大家了解如何解决这类问题. 在解释如何解决订单并发问题之前,需要先了解一下什么是数据库的事务.(我用的是mysql数据库,这里以mysql为例) 1) 事务概念 一组mysql语句,要么执行,要么全不不执行. 2) mysql事务隔离级别 Read Committed(读取提交内容) 如果是Django2.0以下的版本,需要去修改到这个隔离级别,不然乐观锁操作时无法读取已经被修改的数据 Repea
-
golang gin 框架 异步同步 goroutine 并发操作
goroutine机制可以方便地实现异步处理 package main import ( "log" "time" "github.com/gin-gonic/gin" ) func main() { // 1.创建路由 // 默认使用了2个中间件Logger(), Recovery() r := gin.Default() // 1.异步 r.GET("/long_async", func(c *gin.Context) {
-
golang-gin-mgo高并发服务器搭建教程
gin-mgo服务器搭建 该服务器实现简单接收请求并将请求参数封装存储在mongodb数据库中,本文将讲述gin-mgo的使用方法. 项目完整代码地址: https://github.com/wayne-yhp/golang-gin-mgo gin web框架使用介绍 首先获取gin框架依赖 go get gopkg.in/gin-gonic/gin.v1 func main() { server = gin.Default() app.server.GET("/do", IndexR
-
golang高并发限流操作 ping / telnet
需求 当需要同时ping/telnet多个ip时,可以通过引入ping包/telnet包实现,也可以通过go调用cmd命令实现,不过后者调用效率较差,所以这里选择ping包和telnet包 还有就是高并发的问题,可以通过shell脚本或者go实现高并发,所以我选择的用go自带的协程实现,但是如果要同时处理1000+个ip,考虑到机器的性能,需要ratelimit控制开辟的go协程数量,这里主要写一下我的建议和淌过的坑 ping 参考链接: https://github.com/sparrc/go