Golang｜Channel 相关用法理解

news2025/4/20 15:10:26

文章目录

- 用 channel 作为并发小容器
- channel 的遍历
- channel 导致的死锁问题
- 用 channel 传递信号
- 用 channel 并行处理文件
- 用channel 限制接口的并发请求量
- 用 channel 限制协程的总数量

用 channel 作为并发小容器

在这里插入图片描述

注意这里的 ok 如果为 false，表示此时不仅channel为空，而且channel已经被关闭了

channel 的遍历

在这里插入图片描述

注意，遍历会使头指针往后移，相当于取走元素
如果 close channel 注释掉，也不会报错，但是会阻塞，导致输出bye bye这一句代码得不到执行
遍历的另外一种写法

在这里插入图片描述

channel 导致的死锁问题

上面的main方法是等3秒钟结束main协程，更好的方法是使用waitGroup

在这里插入图片描述

如果 close channel 注释掉，程序执行的时候会报错 fatal error: all goroutines are asleep - deadlock!
travese和main都阻塞了

用 channel 传递信号

可以用向channel中传递信号，代替waitGroup，优雅地等子协程结束

在这里插入图片描述

struct{} 空结构体类型，空结构体实例 struct{}{}
空结构体在go语言里是一种特殊的结构体，go语言通过一个统一的引用变量来表示所有的空结构体，而且不占用任何的内存空间
使用空结构体，语义会更加明确且不占内存

在这里插入图片描述

在 Go 语言（Golang）中，reflect 是一个非常强大的包，提供了运行时反射机制，可以在运行时检查变量的类型、获取或设置变量的值。

// 获取类型和值

var x int = 42
t := reflect.TypeOf(x) // reflect.Type
v := reflect.ValueOf(x) // reflect.Value

fmt.Println("类型:", t)      // int
fmt.Println("值:", v.Int()) // 42

// 修改变量的值（需要传指针）

var x int = 10
v := reflect.ValueOf(&x)           // 注意要传指针
v.Elem().SetInt(100)               // 修改值
fmt.Println("x的新值:", x)         // 100

// 检查变量类型

func checkType(i interface{}) {
    t := reflect.TypeOf(i)
    switch t.Kind() {
    case reflect.Int:
        fmt.Println("是整数")
    case reflect.String:
        fmt.Println("是字符串")
    default:
        fmt.Println("其他类型")
    }
}

// 结构体字段操作

type Person struct {
    Name string
    Age  int
}

p := Person{"Tom", 30}
v := reflect.ValueOf(p)
t := reflect.TypeOf(p)

for i := 0; i < t.NumField(); i++ {
    field := t.Field(i)
    value := v.Field(i)
    fmt.Printf("%s: %v\n", field.Name, value)
}

用 channel 并行处理文件

channel 不仅可以当作数据容器使用，也可以当作信号容器来使用
下面这个例子是要把多个txt文件合并为一个txt文件，一个常规的思路就是我们顺序读取文件，每读取一行就把这一行对应地写入到新的文件里面去，但是io操作很消耗时间，且三个文件毫不相关，怎么加速？
考虑三个goroutine并行读，且往一个buffer channel写数据，由一个goroutinue往buffer channel里读数据写入文件，这样可以协调读者和写者的速度不匹配问题

在这里插入图片描述