0

0

如何使用Golang操作通道_Golang channel与sync结合方法

P粉602998670

P粉602998670

发布时间:2026-01-23 10:40:03

|

169人浏览过

|

来源于php中文网

原创

channel不是锁,不能替代sync.Mutex保护临界区;它适用于协程通信、并发控制(如令牌桶)、结果收集(配合sync.WaitGroup)和初始化通知(配合sync.Once),而非原子操作保护。

如何使用golang操作通道_golang channel与sync结合方法

channel 本身不是锁,别用它替代 sync.Mutex

很多人看到 channel 能阻塞、能传递信号,就以为它能当互斥锁用。不能。它解决的是协程间通信与同步,不是临界区保护。比如用 chan struct{} 做“信号量”控制并发数可以,但若用来保护一个全局计数器(如 counter++),依然会竞态——因为 counter++ 不是原子操作,多个 goroutine 在 channel 放行后仍可能同时读-改-写同一变量。

正确做法:需要保护共享数据时,sync.Mutexsync.RWMutex 是首选;channel 用于协调「谁可以去拿锁」「任务分发」「结果收集」等更高层逻辑。

channel 控制并发数量(类似信号量)

这是 channel 最典型且安全的 sync 协作场景:限制同时运行的 goroutine 数量,避免资源耗尽。原理是用带缓冲的 chan struct{} 当令牌桶,每次执行前取一个,结束后还一个。

  • 缓冲容量即最大并发数,例如 make(chan struct{}, 5) 表示最多 5 个 goroutine 并发执行
  • 必须确保每个 goroutine 执行完都调用 done ,否则令牌无法回收,后续任务永久阻塞
  • 不推荐用 close(done) 来释放所有令牌——channel 关闭后不能再写入,会 panic
func main() {
    done := make(chan struct{}, 3) // 最多 3 个并发
    var wg sync.WaitGroup
for i := 0; i zuojiankuohaophpcn 10; i++ {
    wg.Add(1)
    go func(id int) {
        defer wg.Done()
        done zuojiankuohaophpcn- struct{}{} // 拿令牌
        defer func() { zuojiankuohaophpcn-done }() // 还令牌(用 defer 确保执行)

        fmt.Printf("task %d started\n", id)
        time.Sleep(time.Second)
        fmt.Printf("task %d done\n", id)
    }(i)
}

wg.Wait()

}

立即学习go语言免费学习笔记(深入)”;

sync.WaitGroup + channel 安全收集结果

单纯用 channel 接收结果时,如果发送端 panic 或提前退出,接收端可能死锁或漏数据;加上 sync.WaitGroup 可明确知道“所有发送者是否已完成”,再关闭 channel,让接收方安全退出。

蚂蚁PPT
蚂蚁PPT

AI在线智能生成PPT

下载
  • 发送端用 wg.Done() 标记完成,主 goroutine 调用 wg.Wait() 后再 close(ch)
  • 接收端用 for range ch,依赖 channel 关闭自动退出,不会漏也不会卡
  • 不要在发送 goroutine 内部关 channel——多个 goroutine 同时 close 会 panic
func main() {
    ch := make(chan int, 10)
    var wg sync.WaitGroup
// 启动 3 个生产者
for i := 0; i zuojiankuohaophpcn 3; i++ {
    wg.Add(1)
    go func(id int) {
        defer wg.Done()
        for j := 0; j zuojiankuohaophpcn 2; j++ {
            ch zuojiankuohaophpcn- id*10 + j
        }
    }(i)
}

// 启动一个消费者,在所有生产者结束后关闭 channel
go func() {
    wg.Wait()
    close(ch)
}()

// 安全消费
for val := range ch {
    fmt.Println("got:", val)
}

}

立即学习go语言免费学习笔记(深入)”;

sync.Oncechannel 的分工边界

sync.Once 保证某个函数只执行一次,常用于初始化;channel 适合跨 goroutine 通知“初始化已完成”。二者常组合使用,但角色不能颠倒。

  • 不要用 channel 实现 “只执行一次” 逻辑——比如靠第一个往 channel 写值来触发初始化,后续 goroutine 等待读,这容易因调度顺序导致重复初始化或死锁
  • 标准模式是:sync.Once 包裹初始化逻辑,初始化完成后往 channel 发送信号,其他 goroutine 从该 channel 等待就绪通知
  • channel 类型建议用 chan struct{},零内存开销;别用 chan boolchan int 增加无谓负担

真正难处理的是初始化失败后的重试或错误传播——sync.Once 不提供失败重试机制,这时候需要额外状态变量 + channel 配合 error 传递,而不是硬靠 channel 自身语义兜底。

相关专题

更多
golang如何定义变量
golang如何定义变量

golang定义变量的方法:1、声明变量并赋予初始值“var age int =值”;2、声明变量但不赋初始值“var age int”;3、使用短变量声明“age :=值”等等。本专题为大家提供相关的文章、下载、课程内容,供大家免费下载体验。

180

2024.02.23

golang有哪些数据转换方法
golang有哪些数据转换方法

golang数据转换方法:1、类型转换操作符;2、类型断言;3、字符串和数字之间的转换;4、JSON序列化和反序列化;5、使用标准库进行数据转换;6、使用第三方库进行数据转换;7、自定义数据转换函数。本专题为大家提供相关的文章、下载、课程内容,供大家免费下载体验。

228

2024.02.23

golang常用库有哪些
golang常用库有哪些

golang常用库有:1、标准库;2、字符串处理库;3、网络库;4、加密库;5、压缩库;6、xml和json解析库;7、日期和时间库;8、数据库操作库;9、文件操作库;10、图像处理库。本专题为大家提供相关的文章、下载、课程内容,供大家免费下载体验。

340

2024.02.23

golang和python的区别是什么
golang和python的区别是什么

golang和python的区别是:1、golang是一种编译型语言,而python是一种解释型语言;2、golang天生支持并发编程,而python对并发与并行的支持相对较弱等等。本专题为大家提供相关的文章、下载、课程内容,供大家免费下载体验。

209

2024.03.05

golang是免费的吗
golang是免费的吗

golang是免费的。golang是google开发的一种静态强类型、编译型、并发型,并具有垃圾回收功能的开源编程语言,采用bsd开源协议。本专题为大家提供相关的文章、下载、课程内容,供大家免费下载体验。

393

2024.05.21

golang结构体相关大全
golang结构体相关大全

本专题整合了golang结构体相关大全,想了解更多内容,请阅读专题下面的文章。

197

2025.06.09

golang相关判断方法
golang相关判断方法

本专题整合了golang相关判断方法,想了解更详细的相关内容,请阅读下面的文章。

191

2025.06.10

golang数组使用方法
golang数组使用方法

本专题整合了golang数组用法,想了解更多的相关内容,请阅读专题下面的文章。

273

2025.06.17

c++空格相关教程合集
c++空格相关教程合集

本专题整合了c++空格相关教程,阅读专题下面的文章了解更多详细内容。

0

2026.01.23

热门下载

更多
网站特效
/
网站源码
/
网站素材
/
前端模板

精品课程

更多
相关推荐
/
热门推荐
/
最新课程
Go 教程
Go 教程

共32课时 | 4.1万人学习

Go语言实战之 GraphQL
Go语言实战之 GraphQL

共10课时 | 0.8万人学习

关于我们 免责申明 举报中心 意见反馈 讲师合作 广告合作 最新更新
php中文网:公益在线php培训,帮助PHP学习者快速成长!
关注服务号 技术交流群
PHP中文网订阅号
每天精选资源文章推送

Copyright 2014-2026 https://www.php.cn/ All Rights Reserved | php.cn | 湘ICP备2023035733号