go chan基本使用详解
1、有缓冲的chan 与无缓冲的chan
怎么理解这个缓冲，我个人的理解是是执行这个chan 操作的时候是否发送阻塞。
操作：读和写。
读取的时候，我们都应该要是阻塞的，例如我们的socket、的recv函数。当然取决于你设置的是阻塞的套接字还是非阻塞的套接字了。
无缓冲的chan，讲究读写对称，也就是你在读的时候会阻塞，看下面这个例子：ch是一个无缓冲的chan,在主线程里面，ch<-发送了阻塞。所以后面没法执行了。
func TestChan1(t *testing.T) {
ch := make(chan int)
<-ch
ch<-1
}
我们对此进行修改,同样的也是无缓冲的chan,只不过让读操作异步，也就是不是阻塞在主线程了，让主线程可以继续执行。
func TestChan1(t *testing.T) {
ch := make(chan int)
go func() {
val := <-ch
fmt.Println(val)
}()
ch<-1
time.Sleep(1*time.Second)
}
以上是无缓冲chan 的读操作，假设我们是先写呢？我们应该可以猜想到，写可能发生阻塞也可能不发生阻塞。那么无缓冲的chan 到底会不会阻塞呢？我们看下面的例子
func TestChan1(t *testing.T) {
ch := make(chan int)
ch <- 1
<-ch
}
运行之后，发生了死锁。
对此我们可以得出的初步结论是：无缓冲的chan 读写都是阻塞的。
同理我们对此进行修改
func TestChan1(t *testing.T) {
ch := make(chan int)
go func() {
ch <- 1
}()
val := <-ch
fmt.Println(val)
}
无缓冲的chan的介绍，到以上就结束，我们看一下有缓冲的chan。
2、有缓冲的chan
猜想一下有缓冲的chan 是什么存在缓冲，也就是说是读写操作哪个是非阻塞的，还是都是非阻塞的。我们看下面的例子。
第一个例子
func TestChan1(t *testing.T) {
ch := make(chan int,1)
ch <- 1
val := <-ch
fmt.Println(val)
}先写入ch 然后读取。运行
这里我们得到结论：写是非阻塞。
第2 个例子：
func TestChan1(t *testing.T) {
ch := make(chan int,1)
<-ch
ch <- 1
}很显然我们可以猜到，会死锁。运行
对此我们对于有缓冲的chan得出的结论：读取是阻塞的。
同理，针对上面的修改：
func TestChan1(t *testing.T) {
ch := make(chan int,1)
go func() {
val := <-ch
fmt.Println(val)
}()
ch <- 1
time.Sleep(1 *time.Second)
}
对此我们对于chan有了一个基本的认识与使用。接下来看一下chan 几个应用实例。
3、利用chan 实现生产者消费者
生产者与消费者，说白了就是一个线程负责产生数据，另外一端消费数据。对应于我们的读写操作上来，生产者写数据，消费者读数据。对于该模型是不是，很容易利用chan来实现呢？假设我们现在是1个生产者，1个消费者，那么我们应该利用几个chan呢，很显然是一个chan 就够了，因为写入需要阻塞，那么我们的produce 是需要一个线程的，对于消费者，我们也需要一个线程，具体实现：
func TestChan1(t *testing.T) {
ch := make(chan int,1)
defer close(ch)
go func() {
for i := 0;i<10;i++ {
ch<-i
fmt.Println("send:",i)
}
}()
go func() {
for {
select {
case val, ok := <-ch:
if ok {
fmt.Println("recv:", val)
} else {
return
}
}
}
}()
/*go func() {
for c := range ch {
fmt.Println(c)
fmt.Println("recv:",c)
}
}()*/
time.Sleep(1 *time.Second)
}针对接收数据，我们通常采用以下这种模式。
for {
select {
case <- ch:
case <-ctx.Down:
....
}
}4、利用chan 实现同步
两条线程交替打印，例如：1-100，两条线程交替打印。
分析一下这个操作，时间上我们利用的是chan的读取阻塞的特性，实际上就是利用chan 实现同步。
func TestChan1(t *testing.T) {
ch1 := make(chan int)
ch2 := make(chan int)
go func() {
for i := 0; i < 50; i++ {
<-ch1
fmt.Println(2*i + 1)
ch2 <- 1
}
}()
go func() {
for i := 0; i < 50; i++ {
<-ch2
fmt.Println(2*i + 2)
ch1 <- 1
}
}()
ch1 <- 1
time.Sleep(1 * time.Second)
}5、并发处理
假设我们有一个任务，这个任务可以分成很多份，每个任务处理的都是相同的内容，例如多线程查询，汇总。多线程上传。具体的chan 模板代码：
// eg1: 假设10条线程处理，采用10个chan的方式
var res = 0
func TestChan() {
ch := make(chan int,1)
closeCh := make(chan int,1)
defer close(ch)
for i := 1;i<=10;i++ {
item := i
go func() {
ch <- item
}()
}
go func() {
for i := 0;i<10;i++{
c := <- ch
res += c
//fmt.Println(val)
}
closeCh<-1
}()
<-closeCh
fmt.Println(res)
}运行结果
使用waitgroup
func WgTest() {
ch := make(chan int, 1)
closeCh := make(chan int,1)
wg := sync.WaitGroup{}
wg.Add(2)
go Produce(ch,&wg)
go Produce(ch,&wg)
go Merge(ch,closeCh)
wg.Wait()
close(ch)
<-closeCh
fmt.Println(result)
return
}
func Produce(ch chan int, wg *sync.WaitGroup) {
defer func() {
wg.Done()
}()
for i := 0; i < 10; i++ {
ch <- i
}
return
}
var result = 0
func Merge(ch,closeCh chan int) {
for {
select {
case val,ok := <-ch:
if ok {
result += val
}else {
closeCh<-1
return
}
}
}
}到此这篇关于go chan基本使用详解的文章就介绍到这了,更多相关go chan使用内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家！
相关文章
SM4加密算法在安全性、高效性、简单性、标准化和广泛支持等方面具有优势，适用于各种数据保护和加密应用场景，这篇文章就来和大家探索一下Golang中的SM4加密解密算法吧2023-06-06
Golang 在 1.18 版本更新后引入了泛型，这是一个重要的更新，Gopher 万众瞩目，为 Golang 带来了更多的灵活性和可重用性，今天，我们将深入探讨泛型的概念、为什么需要泛型、泛型的语法，并探讨如何在实践中使用它2023-05-05
这篇文章主要介绍了Golang控制协程执行顺序的方法，Golang的语法和运行时直接内置了对并发的支持。Golang里的并发指的是能让某个函数独立于其他函数运行的能力2022-11-11
这篇文章主要介绍了golang编程中函数的用法,是Go语言入门学习中的基础知识,需要的朋友可以参考下2015-10-10
这篇文章主要为大家介绍了GO语言基础库os包的函数全面解析, 有需要的朋友可以借鉴参考下,希望能够有所帮助,祝大家多多进步,早日升职加薪2023-12-12
想知道Go编程语言适合开发哪些类型的项目吗？无论是网络服务、分布式系统还是嵌入式设备,Go都能轻松应对,本文将带你了解Go在各种场景下的应用,让你更好地选择和使用Go进行开发,需要的朋友可以参考下2024-01-01
这篇文章主要为大家介绍了Go分布式链路追踪实战示例探索,有需要的朋友可以借鉴参考下,希望能够有所帮助,祝大家多多进步,早日升职加薪2024-01-01
Go语言的标准库math提供了一系列基础数学函数和常量,用于进行科学计算、几何计算和其他数学相关的操作,这篇文章主要介绍了Go语言标准库中math模块详细功能介绍与示例代码,需要的朋友可以参考下2025-03-03
内存溢出是指程序在申请内存时，没有足够的内存空间供其使用，简单点说就是你要求分配的内存超出了系统能给你的，系统不能满足需求，于是产生溢出出现out of memory异常2022-12-12
这篇文章主要介绍了Golang异常控制处理程序错误流程，Golang异常处理机制包括错误处理、panic和defer，可控制程序错误流程，保证程序稳定性和安全性，是Golang编程的关键方式2023-04-04
最新评论