在Golang中常见的7种阻塞使用方式
Golang 使用 方式 常见 阻塞
2023-06-13 09:18:17 时间
不同方式的阻塞
在工作和学习总,使用Golang的实现业务逻辑的时候,往往需要使流程阻塞一段时间等待其他协程的执行;或者永久阻塞来监听一些连接信息等。下面提供了几种常见的阻塞方式,仅供参考。
1. sync.WaitGroup
sync.WaitGroup
是 Golang 中常用的并发措施,我们可以用它来等待一批 Goroutine 结束。
- Add(): 计数器+1
- Done(): 计数器-1, 当计数器为0时,唤醒Wait挂起的协程
- Wait(): 挂起当前协程
func chokeWithWaitGroup() {
start := time.Now()
wg := sync.WaitGroup{}
// 增加阻塞计数器
wg.Add(1)
go func() {
time.Sleep(chokeTime)
// 扣减阻塞计数器
wg.Done()
}()
// 等待阻塞计数器到 0
wg.Wait()
d := time.Since(start)
fmt.Println("使用WaitGroup阻塞了:", d)
}
2. select
select
是 Go 中的一个控制结构,类似于 switch 语句。
- select 语句只能用于通道操作,每个 case 必须是一个通道操作,要么是发送要么是接收。
- select 语句会监听所有指定的通道上的操作,一旦其中一个通道准备好就会执行相应的代码块。
- 如果多个通道都准备好,那么 select 语句会随机选择一个通道执行。
- 如果所有通道都没有准备好,那么执行 default 块中的代码
func chokeWithSelect() {
start := time.Now()
// 启动定时器
timer := time.NewTimer(chokeTime)
select {
case <-timer.C:
d := time.Since(start)
fmt.Println("使用Select阻塞了:", d)
}
}
3. channel
Go 语言中的通道channel
是一种特殊的类型。
通道像一个传送带或者队列,总是遵循先入先出(First In First Out)的规则,保证收发数据的顺序。
当没有给channel设置空间的时候,称为无缓冲通道或者阻塞通道或者同步通道。
func chokeWithChannel() {
start := time.Now()
var ch = make(chan struct{})
go func() {
time.Sleep(chokeTime)
ch <- struct{}{}
}()
// 阻塞,等待channel数据
if _, ok := <-ch; ok {
d := time.Since(start)
fmt.Println("使用channel阻塞了:", d)
}
}
4. time.After
Go 语言中的time包提供了时间的显示和测量用的函数。其中time.After
会在一段时间后返回一个时间信号。且是一次性的定时。
因此,可以通过time.After来阻塞固定时长。
func chokeWithTimeAfter() {
start := time.Now()
<-time.After(chokeTime)
d := time.Since(start)
fmt.Println("使用channel阻塞了:", d)
}
5. for
使用for{}
循环来控制阻塞,这个不需要解释了。但是会一直占用CPU的资源,慎用。
func chokeWithFor() {
start := time.Now()
for {
d := time.Since(start)
if d > chokeTime {
fmt.Println("使用For阻塞了:", d)
return
}
}
}
6. mutex
使用mutex
锁的时候,如果多个协程同时想要获取锁,那么就会出现竞争关系。当第二个协程在尝试获取锁的时候,发现锁已经被其他协程占用,则会一直不停的尝试获取锁,形成阻塞。
func chokeWithMutex() {
start := time.Now()
mu := sync.Mutex{}
mu.Lock()
go func() {
mu.Lock()
defer mu.Unlock()
d := time.Since(start)
fmt.Println("使用mutex阻塞了:", d)
}()
time.Sleep(chokeTime)
mu.Unlock()
time.Sleep(chokeTime)
}
7. goto
goto
是调整代码执行位置,如果形成了一个循环的化,同样会阻塞程序。
func chokeWithGoto() {
start := time.Now()
here:
d := time.Since(start)
if d > chokeTime {
fmt.Println("使用Goto阻塞了:", d)
return
}
goto here
}
完整代码示例
方法
package choke
import (
"fmt"
"sync"
"time"
)
var chokeTime = 1 * time.Second
// chokeWithWaitGroup 使用WaitGroup()控制阻塞
func chokeWithWaitGroup() {
start := time.Now()
wg := sync.WaitGroup{}
// 增加阻塞计数器
wg.Add(1)
go func() {
time.Sleep(chokeTime)
// 扣减阻塞计数器
wg.Done()
}()
// 等待阻塞计数器到 0
wg.Wait()
d := time.Since(start)
fmt.Println("使用WaitGroup阻塞了:", d)
}
// chokeWithSelect 使用select控制阻塞
func chokeWithSelect() {
start := time.Now()
// 启动定时器
timer := time.NewTimer(chokeTime)
select {
case <-timer.C:
d := time.Since(start)
fmt.Println("使用Select阻塞了:", d)
}
}
// chokeWithFor 使用for控制阻塞
func chokeWithFor() {
start := time.Now()
for {
d := time.Since(start)
if d > chokeTime {
fmt.Println("使用For阻塞了:", d)
return
}
}
}
// chokeWithMutex 使用mutex控制阻塞
func chokeWithMutex() {
start := time.Now()
mu := sync.Mutex{}
mu.Lock()
go func() {
mu.Lock()
defer mu.Unlock()
d := time.Since(start)
fmt.Println("使用mutex阻塞了:", d)
}()
time.Sleep(chokeTime)
mu.Unlock()
time.Sleep(chokeTime)
}
// chokeWithChannel 使用channel控制阻塞
func chokeWithChannel() {
start := time.Now()
var ch = make(chan struct{})
go func() {
time.Sleep(chokeTime)
ch <- struct{}{}
}()
// 阻塞,等待channel数据
if _, ok := <-ch; ok {
d := time.Since(start)
fmt.Println("使用channel阻塞了:", d)
}
}
// chokeWithTimeAfter 使用time.After控制阻塞
func chokeWithTimeAfter() {
start := time.Now()
<-time.After(chokeTime)
d := time.Since(start)
fmt.Println("使用channel阻塞了:", d)
}
// chokeWithGoto 使用goto控制阻塞
func chokeWithGoto() {
start := time.Now()
here:
d := time.Since(start)
if d > chokeTime {
fmt.Println("使用Goto阻塞了:", d)
return
}
goto here
}
测试
package choke
import "testing"
func TestChoke(t *testing.T) {
chokeWithWaitGroup()
chokeWithSelect()
chokeWithChannel()
chokeWithTimeAfter()
chokeWithFor()
chokeWithMutex()
chokeWithGoto()
}
执行结果
=== RUN TestChoke
使用WaitGroup阻塞了: 1.000691546s
使用Select阻塞了: 1.001008044s
使用For阻塞了: 1.000650866s
使用mutex阻塞了: 1.000067636s
使用channel阻塞了: 1.00013111s
使用channel阻塞了: 1.000485065s
使用Goto阻塞了: 1.000000004s
--- PASS: TestChoke (8.00s)
PASS
Process finished with the exit code 0
相关文章
- Fabric.js 使用纯色遮挡画布(前景色)
- 仙人指路,引而不发,Go lang1.18入门精炼教程,由白丁入鸿儒,Golang中New和Make函数的使用背景和区别EP16
- GoLang读写数据---中
- GoLang的安装和使用
- Golang的slice
- golang下文件锁的使用[通俗易懂]
- Golang 和 Python 的 OCR 服务安装及使用
- go struct转map_golang map
- linkedhashset有序吗_golang人工智能框架
- spring cloud gateway 网关认证登录_golang 网关
- Golang开发环境搭建(Windows)[通俗易懂]
- golang源码分析:grpc 链接池(5)自定义组件和框架交互流程
- Golang Context 详细原理和使用技巧
- Go 单测入门篇:Golang 单元测试基本使用
- 使用 Golang 正确处理五大互联网注册机构的 IP 数据
- golang源码分析:http代理和https代理
- golang 反射1: 使用反射绑定 cobra flag 参数
- golang使用multiconfig后导致glog无法接受命令行参数
- 使用 GOLANG 发送邮件
- 为什么使用 golang http包 会把 linux 句柄打满?
- Golang标准库-sync包使用和应用场景
- Golang channel 用法与实现原理
- 手把手教你用golang撸rpc
- golang使用JWX进行认证和加密
- Golang 防止路径遍历漏洞
- 「Golang反射实战2」 使用接口实现 深拷贝(deepcopy)
- 2023-04-04:使用 Golang 和 ffmpeg-go 库实现 demuxing_decoding.c,轻松掌握音视频分离解码技巧。
- 2023-04-09:使用 Golang 重写的 ffmpeg 示例encode_video.c,实现视频编码并将编码后的数据封装为容器格式,最终写入输出文件。
- Golang Context 探究
- MacOS系统安装golang教程