【Java转Go】快速上手学习笔记（四）之基础篇三

目录

  • 泛型
    • 内置泛型的使用
    • 切片泛型和泛型函数
    • map泛型
    • 泛型约束
    • 泛型完整代码
  • 接口
  • 反射
  • 协程
    • 特点
    • WaitGroup
    • goroutine的调度模型：MPG模型
  • channel
    • 介绍
    • 语法：
    • 举例：
    • channel遍历
    • 基本使用
    • 和协程一起使用
      • 案例一
      • 案例二
    • select...case
    • main.go 完整代码
  • 文件

go往期文章笔记：

【Java转Go】快速上手学习笔记（一）之环境安装篇

【Java转Go】快速上手学习笔记（二）之基础篇一

【Java转Go】快速上手学习笔记（三）之基础篇二


这篇主要是泛型、接口、反射、协程、管道、文件操作的笔记，因为我的笔记都是按照视频说的来记的，可能大家光看的话会有些看不明白，所以建议大家可以把代码复制下来，配合里面的注释一起，自己去运行一遍，加深理解😘


泛型

定义泛型：func 函数名 [泛型参数类型] (函数参数) {}

内置泛型的使用

Go内置的两个泛型：any 和 comparable

  • any：表示go里面所有的内置基本类型，等价于 interface{}
  • comparable：表示go里面所有内置的可比较类型：int、uint、float、booi.struct、指针 等一切可以比较的类型
func printArr[T any](arr []T) {for _, item := range arr {fmt.Println(item)}
}// 泛型的使用
func 泛型的基本使用() {strArr := []string{"白夜", "炽翎"}intArr := []int{1, 2}printArr(strArr)printArr(intArr)
}

切片泛型和泛型函数

// 自定义一个切片泛型
type mySlice[T int | float64] []T// 给自定义的切片泛型添加一个求和方法
func (s mySlice[T]) sum() T {var sum Tfor _, v := range s {sum += v}return sum
}// 定义一个泛型函数
func add[T int | float64 | float32 | string](a T, b T) T {return a + b
}// 泛型函数与方法
func 切片泛型的使用() {// 往自定义的切片泛型里，添加int类型的值var i mySlice[int] = []int{1, 2, 3, 4}fmt.Println(i.sum()) // 可以直接调用为切片泛型添加的一个求和方法// 往自定义的切片泛型里，添加float64类型的值var f mySlice[float64] = []float64{1.5, 2.7, 3.89, 4.55}fmt.Println(f.sum())//fmt.Println(add[int](1, 2))fmt.Println(add(1, 2)) // 调用时，可以自动推导传入的参数的类型//fmt.Println(add[string]("hh", "66"))fmt.Println(add("hh", "66"))//fmt.Println(add[float64](1.6, 2.8))fmt.Println(add(1.6, 2.8))
}

map泛型

// 泛型map
type myMap[K string | int, V any] map[K]V
type User struct {Name string
}func map泛型的使用() {m1 := myMap[string, string]{"key": "符华",}fmt.Println(m1)m2 := myMap[int, User]{0: User{"符华"},}fmt.Println(m2)
}

泛型约束

// 自定义一个类型别名（将int8类型设置一个别名）
type int8A int8// 自定义一个泛型约束
type myInt interface {// 当类型设置了别名，在使用的时候要么在后面把这个别名约束也加进去//int | int8 | int16 | int32 | int64 | int8A// 要么在这个类型前面，加一个 ~ 符号，因为类型的别名是这个类型的衍生类型，在类型前面加 ~ 号就可以适配这个类型的全部衍生类型了int | ~int8 | int16 | int32 | int64
}// 给泛型约束定义一个比较大小的泛型函数
func getMaxNum[T myInt](a, b T) T {if a > b {return a}return b
}func 泛型约束的使用() {//var a int = 10var a int8A = 10//var b int = 20var b int8A = 20fmt.Println(getMaxNum(a, b))
}

泛型完整代码

package mainimport "fmt"/*
泛型：内置的泛型类型 any 和 comparable
any：表示go里面所有的内置基本类型，等价于 interface{}
comparable：表示go里面所有内置的可比较类型：`int、uint、float、booi.struct、指针` 等一切可以比较的类型
*/
func printArr[T any](arr []T) {for _, item := range arr {fmt.Println(item)}
}// 自定义一个切片泛型
type mySlice[T int | float64] []T// 给自定义的切片泛型添加一个求和方法
func (s mySlice[T]) sum() T {var sum Tfor _, v := range s {sum += v}return sum
}// 泛型函数
func add[T int | float64 | float32 | string](a T, b T) T {return a + b
}// 泛型map
type myMap[K string | int, V any] map[K]V
type User struct {Name string
}// 自定义一个类型别名（将int8类型设置一个别名）
type int8A int8// 自定义一个泛型约束
type myInt interface {// 当类型设置了别名，在使用的时候要么在后面把这个别名约束也加进去//int | int8 | int16 | int32 | int64 | int8A// 要么在这个类型前面，加一个 ~ 符号，因为类型的别名是这个类型的衍生类型，在类型前面加 ~ 号就可以适配这个类型的全部衍生类型了int | ~int8 | int16 | int32 | int64
}// 给泛型约束定义一个比较大小的泛型函数
func getMaxNum[T myInt](a, b T) T {if a > b {return a}return b
}func main() {//泛型的基本使用()//切片泛型的使用()//map泛型的使用()泛型约束的使用()
}// 泛型的使用
func 泛型的基本使用() {strArr := []string{"白夜", "炽翎"}intArr := []int{1, 2}printArr(strArr)printArr(intArr)
}// 泛型函数与方法
func 切片泛型的使用() {// 往自定义的切片泛型里，添加int类型的值var i mySlice[int] = []int{1, 2, 3, 4}fmt.Println(i.sum()) // 可以直接调用为切片泛型添加的一个求和方法// 往自定义的切片泛型里，添加float64类型的值var f mySlice[float64] = []float64{1.5, 2.7, 3.89, 4.55}fmt.Println(f.sum())//fmt.Println(add[int](1, 2))fmt.Println(add(1, 2)) // 调用时，可以自动推导传入的参数的类型//fmt.Println(add[string]("hh", "66"))fmt.Println(add("hh", "66"))//fmt.Println(add[float64](1.6, 2.8))fmt.Println(add(1.6, 2.8))
}func map泛型的使用() {m1 := myMap[string, string]{"key": "符华",}fmt.Println(m1)m2 := myMap[int, User]{0: User{"符华"},}fmt.Println(m2)
}func 泛型约束的使用() {//var a int = 10var a int8A = 10//var b int = 20var b int8A = 20fmt.Println(getMaxNum(a, b))
}

接口

接口：用 type 和 interface 关键字定义

定义格式：

type 接口名 interface {接口方法1(参数1 参数类型.....) [返回类型]接口方法2() [返回类型]接口方法3()...接口方法n() [返回类型]
}

接口可以将不同的类型绑定到一组公共的方法上，从而实现多态。（提高代码的复用率）

Go中的接口是隐式实现的，也就是说，如果一个类型实现了一个接口定义的所有方法，那么它就自动地实现了该接口。（不用像Java一样，用implements关键字指定实现哪个接口）

因此，我们可以通过将接口作为参数来实现对不同类型的调用，从而实现多态。

// 定义一个 寸劲 接口
type 寸劲 interface {// 这个接口里面有这几个方法寸劲开天(days int) string // 有参数，有返回值的方法寸劲山崩() string         // 无参数，有返回值的方法寸劲岩破()                // 无参数，无返回值的方法
}// 定义一个 太虚剑气 接口
type 太虚剑气 interface {太虚剑神(days int) string
}// 定义一个函数，以空接口作为参数（可以传任何类型的参数）
func dataPrint(datas ...interface{}) {for i, x := range datas {switch x.(type) {case bool:fmt.Printf("参数 #%d 是一个bool类型，它的值是：%v\n", i, x)case string:fmt.Printf("参数 #%d 是一个string类型，它的值是：%v\n", i, x)case int:fmt.Printf("参数 #%d 是一个int类型，它的值是：%v\n", i, x)case float64:fmt.Printf("参数 #%d 是一个float64类型，它的值是：%v\n", i, x)case nil:fmt.Printf("参数 #%d 是一个nil类型，它的值是：%v\n", i, x)default:fmt.Printf("参数 #%d 是其他类型，它的值是：%v\n", i, x)}}
}// 定义一个用户学习结构体，来实现接口所有个方法（一个类型实现了接口的所有方法，即实现了该接口）
type 学习 struct {name string
}// 定义一个结构体特有的方法
func (x 学习) 开始学习() string {return fmt.Sprint(x.name, "现在要开始学习了.....")
}// 实现 寸劲开天 接口（这里也可以用指针 x *学习，用了指针后，那么赋值的时候也需要传指针类型：&学习{"符华"}）
func (x *学习) 寸劲开天(days int) string {return fmt.Sprint(x.name, "学了", days, "天，学完了寸劲开天")
}// 实现 寸劲山崩 接口
func (x 学习) 寸劲山崩() string {return fmt.Sprint(x.name, "学完了寸劲山崩")
}// 实现 寸劲岩破 接口
func (x 学习) 寸劲岩破() {fmt.Println(x.name, "学完了寸劲岩破")
}// 实现 太虚剑神 接口
func (x *学习) 太虚剑神(days int) string {return fmt.Sprint(x.name, "学了", days, "天，学完了太虚剑神")
}func main() {接口的使用()
}func 接口的使用() {u := 学习{"符华"}var cj 寸劲//cj = u // 接口赋值为 学习 结构体，只有当实现了接口的全部方法才能赋值给接口，否则无法赋值cj = &u                     // 只要接口方法有一个指针实现，则此处必须是指针if u1, ok := cj.(*学习); ok { // 通过类型断言，来调用 结构体 独有的方法fmt.Println(u1.开始学习())}cj.寸劲岩破()fmt.Println(cj.寸劲山崩())fmt.Println(cj.寸劲开天(2))/*类型断言：由于接口是一般类型，不知道具体类型，如果要转成具体类型，就需要使用类型断言语法：接口.(类型)，类型不是什么类型都可以传，必须要 接口 原先指向什么类型，那么就传什么类型返回两个值，可以通过返回的 true、false 来判断断言（转换）是否成功*///var jq 太虚剑气//jq, ok := cj.(太虚剑气)if jq, ok := cj.(太虚剑气); ok { // 如果转换成功，ok为truefmt.Println(jq.太虚剑神(10))} else {fmt.Println("转换失败")}var a interface{}a = u // 将 u 赋值给a，然后将 a 重新赋值给一个 学习 类型的变量，这就需要用 类型断言var u1 学习//u1 = a // 这里不可以直接赋值，需要使用类型断言u1 = a.(学习) // a 原先指向 学习 类型，所以传类型时也必须要传 学习 类型fmt.Println(u1)// 空接口dataPrint(u, "空接口", 123, 12.65, []int{1, 2, 3}, make(map[string]string, 2))
}

反射

Go中，使用反射需要导入 reflect 包

使用反射时，主要有两个很重要的方法：

  • reflect.TypeOf(变量名)，获取变量的类型，返回 reflect.Type 类型（是一个接口）
  • reflect.ValueOf(变量名)，获取变量的值，返回 reflect.Value 类型（是一个结构体类型）

变量、interface{} 和 reflect.Value 是可以相互转换的，如下图：

在这里插入图片描述

package mainimport ("fmt""reflect"
)/*
反射：需要导入 reflect 包
主要有两个函数：reflect.TypeOf(变量名)，获取变量的类型，返回 reflect.Type 类型（是一个接口）reflect.ValueOf(变量名)，获取变量的值，返回 reflect.Value 类型（是一个结构体类型）变量、interface{}和 reflect.Value 是可以相互转换的
*/type student struct {Name string `json:"name"`Age  int
}// 给 student 结构体绑定方法
func (s student) PrintStu() {fmt.Println(s)
}
func (s student) GetSum(a, b int) {fmt.Println(a + b)
}// 基本数据类型、interface{}、reflect.Value 相互转换
func reflectTest01(a interface{}) {// 通过反射获取传入的变量的 typerTyp := reflect.TypeOf(a)fmt.Println("rTyp=", rTyp)// 获取到 reflect.ValuerVal := reflect.ValueOf(a)n1 := 10 + rVal.Int() // 通过反射来获取变量的值，要求数据类型匹配：reflect.Value.Int()、reflect.Value.String()、reflect.Value.Float()......fmt.Println(n1)fmt.Printf("rVal=%v ， rVal的类型=%T\n", rVal, rVal)// 将 reflect.Value 转回 interface{}iV := rVal.Interface()// 将 interface{} 通过断言转回 需要的类型n2 := iV.(int)fmt.Println(n2)
}// 对结构体的反射
func reflectTest02(a interface{}) {// 通过反射获取传入的变量的 typerTyp := reflect.TypeOf(a)fmt.Println("rTyp=", rTyp)// 获取到 reflect.ValuerVal := reflect.ValueOf(a)fmt.Printf("rVal=%v ， rVal的类型=%T\n", rVal, rVal)fmt.Println("kind=", rVal.Kind(), rTyp.Kind())// 将 reflect.Value 转回 interface{}iV := rVal.Interface()// 通过反射来获取结构体的值，需要先断言// 将 interface{} 通过断言转回 需要的类型stu := iV.(student)fmt.Println(stu)
}// 通过反射改变值（必须传入指针，才能改变值）
func reflectTest03(a interface{}) {rTyp := reflect.TypeOf(a) // 通过反射获取传入的变量的 typefmt.Println("rTyp=", rTyp)rVal := reflect.ValueOf(a) // 获取到 reflect.Valueswitch a.(type) {          // 判断传入的参数的类型case *int:n1 := 10 + rVal.Elem().Int() // 通过反射来获取变量的值，因为传入的是指针，所以要先用 Elem() 再获取值fmt.Println(n1)fmt.Printf("rVal=%v ， rVal的类型=%T\n", rVal.Elem(), rVal)rVal.Elem().SetInt(200) // 通过反射改变值case *student:e := rVal.Elem()e.FieldByName("Name").SetString("白夜") // 给指定的字段名改变值}
}// 通过反射遍历结构体的方法和属性
func reflectTest04(a interface{}) {rTyp := reflect.TypeOf(a)if rTyp.Kind() != reflect.Struct { // 判断传入的参数是否是结构体return}rVal := reflect.ValueOf(a)// 遍历结构体字段numField := rTyp.NumField() // 获取结构体字段的数量fmt.Println("numField =", numField)for i := 0; i < numField; i++ {// 打印字段的类型、字段名、字段值、字段标签fmt.Println(rTyp.Field(i).Type, rTyp.Field(i).Name, "=", rVal.Field(i), rTyp.Field(i).Tag.Get("json"))}// 遍历结构体方法numMethod := rTyp.NumMethod() // 获取结构体方法的数量// 关于方法遍历时，方法的索引：是根据方法名称的ACSII码来排序的for i := 0; i < numMethod; i++ {// 打印方法的类型、方法名//fmt.Println(rTyp.Method(i).Type, rTyp.Method(i).Name)if i == 0 {var params []reflect.Valueparams = append(params, reflect.ValueOf(10))params = append(params, reflect.ValueOf(20))rVal.Method(i).Call(params)} else {rVal.Method(i).Call(nil)}}
}func main() {// 基本数据类型、interface{}、reflect.Value 相互转换//var num int = 100//reflectTest01(num)//reflectTest03(&num) // 修改值必须传指针//fmt.Println("通过反射改变num的值", num)stu := student{"符华", 20}//reflectTest02(stu)//reflectTest03(&stu) // 修改值必须传指针//fmt.Println("通过反射改变stu的值", stu)reflectTest04(stu)
}

协程

接下来我们讲协程

协程：一个进程有多个线程，一个线程可以起多个协程

特点

  • 有独立的栈空间
  • 共享程序堆空间
  • 调度由用户控制
  • 协程是轻量级的线程

主线程结束后，协程会被中断，这时需要一个有效的阻塞机制。

WaitGroup

如果主线程退出了，即使协程还没有执行完毕，也会退出。这时，我们可以使用WaitGroup，它用于等待一组协程的结束。

  • 父线程调用Add方法来设定应等待的协程的数量。
  • 每个被等待的协程在结束时应调用Done方法。
  • 同时，主线程里可以调用Wait方法阻塞至所有协程结束。

goroutine的调度模型：MPG模型

  • M：操作系统的主线程（是物理线程）
  • P：协程执行需要的上下文
  • G：协程

使用 goroutine 效率高，但是会出现并发/并行安全问题，需要加锁解决这个问题。

如果协程发生异常，可以用recover来捕获异常，进行除了。这样主函数不会受到影响，可以继续执行。

package mainimport ("fmt""strconv""sync""time"
)// 一个函数，每隔1秒输出
func goroutineTest01() {for i := 0; i < 10; i++ {fmt.Println("test() hello,world " + strconv.Itoa(i))time.Sleep(time.Second)}
}var (myMap = make(map[int]int, 10)// 定义一个全局的互斥锁lock sync.Mutex     // sync 同步的意思，Mutex 互斥的意思wg   sync.WaitGroup // 用于等待一组线程的结束
)func goroutineTest02(n int) {res := 1for i := 1; i <= n; i++ {res *= i}lock.Lock()    // 写之前加锁myMap[n] = res // concurrent map writes 并发写入问题lock.Unlock()  // 写完之后解锁//wg.Add()中有20个需要执行的协程，每执行完一个后调用wg.Done()，让协程数量-1，直到协程数量为0，表示全部协程执行完毕wg.Done() // 这里表示每执行完一个协程，wg.Add()里面的数量-1
}func main() {协程()
}func 协程() {//goroutineTest01() // 如果这样调用，这里是先执行完goroutineTest01，再执行main里面的打印//go goroutineTest01() // 开启了一个线程，这样goroutineTest01和main就是同时执行//for i := 0; i < 10; i++ {//	fmt.Println("main() hello,world " + strconv.Itoa(i))//	time.Sleep(time.Second)//}//cpuNum := runtime.NumCPU() //获取电脑的cpu数量//fmt.Println("cpu个数：", cpuNum)// 可以自己设置使用多少个cpu//runtime.GOMAXPROCS(cpuNum - 1) // 预留一个cpuwg.Add(20) // 这里表示有20个协程需要执行// 开启多个协程for i := 1; i <= 20; i++ {go goroutineTest02(i)}wg.Wait() // 告诉主线程要等一下，等协程全部执行完了载退出fmt.Println("全部协程执行完毕")// 遍历输出map结果for i, v := range myMap {fmt.Printf("map[%d]=%d\n", i, v)}
}func 协程异常捕获() {// 这里我们可以使用defer + recover来捕获异常defer func() {if err := recover(); err != nil {fmt.Println("发生错误，错误信息：", err)}}()var myMap map[int]stringmyMap[0] = "Go" // map没有make，出现error
}

channel

channel也就是管道，一般情况下，我们是配合协程一起使用的。

channel管道：本质就是一个数据结构——队列

介绍

  • 数据是先进先出：FIFO：first in first out
  • 线程安全，多goroutine访问时，不需要加锁，就是说channel本身就是线程安全的
  • channel是有类型的，一个string的channel只能存放string类型数据
  • channel必须是引用类型，必须初始化才能写入数据，也就是需要make后才能使用

语法：

var 变量名 chan 数据类型，变量名 = make(chan 数据类型, 容量) （使用make进行初始化）

举例：

var intChan chan int // 用于存放int数据
var mapChan chan map[int]string // 用于存放map[int]string数据
var perChan chan Pserson // 用于存放Pserson结构体数据
var perChan1 chan *Pserson //用于存放Pserson结构体指针数据
var perChan1 chan interface{} //可以存放任何类型数据，但是取的时候要注意用类型断言

channel遍历

  • 通常使用for-range方式进行遍历，不用取长度的方式来遍历管道是因为管道每取一次，长度就会变。

  • 在遍历时，如果管道没有关闭，会出现deadlock的错误；如果管道已经关闭，则正常遍历数据，遍历完后，退出遍历。

管道可以声明为只读或只写（默认情况下是双向的，也就是可读可写）

  • 只写：var intChan chan<- int
  • 只读：var intChan <-chan int

基本使用

func 管道() {// 创建一个可以存放3个int类型的管道var intChan chan int// 因为channel是引用类型，它的值其实是一个地址，然后这个地址指向的就是管道队列；然后intChan本身也有一个地址intChan = make(chan int, 3)fmt.Printf("intChan 的值=%v intChan 本身的地址=%p\n", intChan, &intChan) // intChan 的值=0xc00006e080 intChan 本身的地址=0xc00004c020// 向管道写入数据，写入、读取管道数据时，用 <- 表达式intChan <- 10num := 200intChan <- num// 设置的管道容量是3，最多只能往里面写入3条数据（长度不能超过容量）intChan <- 100// 管道的长度和cap（容量）fmt.Printf("管道 长度 = %v 容量 = %v\n", len(intChan), cap(intChan)) // 3,3// 读取管道的数据。从管道中取出了数据，可以再往里面放数据//<-intChan // 可以直接这么写，也是取出数据；不用变量接收，把取出的数据扔了不要n1 := <-intChan                                                // 这里取出来的是最先写入到管道里的数据（先进先出）fmt.Println("n1=", n1)                                         // 10fmt.Printf("管道 长度 = %v 容量 = %v\n", len(intChan), cap(intChan)) // 2,3// 取出了一条数据后再往里面放一条数据intChan <- 500close(intChan)                                                 // 关闭管道，这时就不能再往管道里面写入数据了，但是读取没问题fmt.Printf("管道 长度 = %v 容量 = %v\n", len(intChan), cap(intChan)) // 3,3// 在没有使用协程的情况下，如果管道数据已经全部取出，再取会报错n2 := <-intChann3 := <-intChanfmt.Printf("n2 = %v n3 = %v\n", n2, n3)                        // 200,100fmt.Printf("管道 长度 = %v 容量 = %v\n", len(intChan), cap(intChan)) // 1,3// 遍历管道intChan2 := make(chan int, 100)for i := 0; i < 100; i++ {intChan2 <- i * 2}close(intChan2) // 管道写完数据后，先将管道关闭，再进行遍历// 不能用取长度的方式来遍历管道，因为管道每取一次，长度就会变，要用 range 方式遍历for v := range intChan2 { // 这里只返回一个数据，管道里面没有下标fmt.Println("v =", v)}
}

和协程一起使用

案例一

package mainimport ("fmt""sync"
)// 全局 WaitGroup 变量
var wg sync.WaitGroup // 用于等待一组线程的结束// 管道写入数据
func writeData(intChan chan int) {for i := 0; i < 50; i++ {intChan <- ifmt.Printf("writeData 写入数据=%v\n", i)}close(intChan)wg.Done() // 执行完一个线程后，调用这个方法，主线程中需要等待执行的协程数量-1
}// 管道读取数据
func readData(intChan chan int) {for {v, ok := <-intChanif !ok {break}fmt.Printf("readData 读到数据=%v\n", v)}wg.Done() // 执行完一个线程后，调用这个方法，主线程中需要等待执行的协程数量-1
}func main() {协程和管道应用1()
}func 协程和管道应用1() {// 创建两个管道intChan := make(chan int, 10)wg.Add(2) // 说明开启了两个线程// 开启了两个协程，writeData和readData应该是交叉执行的go writeData(intChan) // 开启一个协程，往 intChan 中写入数据go readData(intChan)  // 开启一个协程，读取 intChan 的数据wg.Wait()             // 告诉主线程需要等待协程执行完毕fmt.Println("程序执行完毕！")
}

案例二

  • 需求：要求统计1-8000的数字中，哪些是素数

  • 将统计素数的任务，分配给4个协程去完成

// 判断是否为素数
func isPrime(intChan, primeChan chan int) {var isPrime bool // 标识是否是素数for v := range intChan {isPrime = truefor i := 2; i < v; i++ {if v%i == 0 {isPrime = falsebreak}}if isPrime { // 如果为素数，则往primeChan中写入数据primeChan <- v}}fmt.Println("isPrime 读取素数完毕")wg.Done() // 执行完一个线程后，调用这个方法，主线程中需要等待执行的协程数量-1
}func 协程和管道应用2() {// 需求：要求统计1-8000的数字中，哪些是素数// 将统计素数的任务，分配给4个协程去完成intChan := make(chan int, 1000)   // 读写1-8000数字的管道primeChan := make(chan int, 2000) // 存储素数的管道wg.Add(5)                         // 下面开启了5个协程// 开启写入 1-8000 数字的协程go func() {for i := 1; i <= 8000; i++ {intChan <- i}close(intChan)wg.Done()}()// 开启4个读取 1-8000 数字，并统计素数的协程for i := 0; i < 4; i++ {go isPrime(intChan, primeChan)}wg.Wait()        // 等待协程执行完毕close(primeChan) // 关闭 primeChan 管道// 遍历primeChan，把结果取出来for v := range primeChan {fmt.Printf("素数是 = %v\n", v)}
}

select…case

传统的方法在遍历管道时，如果不关闭会阻塞而导致 deadlock。

在实际开发中，可能不好确定什么时候关闭管道，这时可以使用select方式解决。

func 管道注意细节() {intChan := make(chan int, 10)for i := 0; i < 10; i++ {intChan <- i}stringChan := make(chan string, 5)for i := 0; i < 5; i++ {stringChan <- "hello" + fmt.Sprintf("%d", i)}// 传统的方法在遍历管道时，如果不关闭会阻塞而导致 deadlock// 在实际开发中，可能不好确定什么时候关闭管道，这时可以使用select方式解决for {select {// 这里如果intChan一直没有关闭，也不会一直阻塞而导致deadlock// 如果一个case取不到数据，会自动到下一个case中取case v := <-intChan:fmt.Println("从intChan读取的数据=", v)case v := <-stringChan:fmt.Println("从stringChan读取的数据=", v)default:fmt.Println("都取不到了")return}}
}

main.go 完整代码

package mainimport ("fmt""sync"
)var wg sync.WaitGroup // 用于等待一组线程的结束// 管道写入数据
func writeData(intChan chan int) {for i := 0; i < 50; i++ {intChan <- ifmt.Printf("writeData 写入数据=%v\n", i)}close(intChan)wg.Done() // 执行完一个线程后，调用这个方法，主线程中需要等待执行的协程数量-1
}// 管道读取数据
func readData(intChan chan int) {for {v, ok := <-intChanif !ok {break}fmt.Printf("readData 读到数据=%v\n", v)}wg.Done() // 执行完一个线程后，调用这个方法，主线程中需要等待执行的协程数量-1
}// 判断是否为素数
func isPrime(intChan, primeChan chan int) {var isPrime bool // 标识是否是素数for v := range intChan {isPrime = truefor i := 2; i < v; i++ {if v%i == 0 {isPrime = falsebreak}}if isPrime { // 如果为素数，则往primeChan中写入数据primeChan <- v}}fmt.Println("isPrime 读取素数完毕")wg.Done() // 执行完一个线程后，调用这个方法，主线程中需要等待执行的协程数量-1
}func main() {//管道()//协程和管道应用1()//协程和管道应用2()//管道注意细节()
}func 管道() {// 创建一个可以存放3个int类型的管道var intChan chan int// 因为channel是引用类型，它的值其实是一个地址，然后这个地址指向的就是管道队列；然后intChan本身也有一个地址intChan = make(chan int, 3)fmt.Printf("intChan 的值=%v intChan 本身的地址=%p\n", intChan, &intChan) // intChan 的值=0xc00006e080 intChan 本身的地址=0xc00004c020// 向管道写入数据，写入、读取管道数据时，用 <- 表达式intChan <- 10num := 200intChan <- num// 设置的管道容量是3，最多只能往里面写入3条数据（长度不能超过容量）intChan <- 100// 管道的长度和cap（容量）fmt.Printf("管道 长度 = %v 容量 = %v\n", len(intChan), cap(intChan)) // 3,3// 读取管道的数据。从管道中取出了数据，可以再往里面放数据//<-intChan // 可以直接这么写，也是取出数据；不用变量接收，把取出的数据扔了不要n1 := <-intChan                                                // 这里取出来的是最先写入到管道里的数据（先进先出）fmt.Println("n1=", n1)                                         // 10fmt.Printf("管道 长度 = %v 容量 = %v\n", len(intChan), cap(intChan)) // 2,3// 取出了一条数据后再往里面放一条数据intChan <- 500close(intChan)                                                 // 关闭管道，这时就不能再往管道里面写入数据了，但是读取没问题fmt.Printf("管道 长度 = %v 容量 = %v\n", len(intChan), cap(intChan)) // 3,3// 在没有使用协程的情况下，如果管道数据已经全部取出，再取会报错n2 := <-intChann3 := <-intChanfmt.Printf("n2 = %v n3 = %v\n", n2, n3)                        // 200,100fmt.Printf("管道 长度 = %v 容量 = %v\n", len(intChan), cap(intChan)) // 1,3// 遍历管道intChan2 := make(chan int, 100)for i := 0; i < 100; i++ {intChan2 <- i * 2}close(intChan2) // 管道写完数据后，先将管道关闭，再进行遍历// 不能用取长度的方式来遍历管道，因为管道每取一次，长度就会变，要用 range 方式遍历for v := range intChan2 { // 这里只返回一个数据，管道里面没有下标fmt.Println("v =", v)}
}func 协程和管道应用1() {// 创建两个管道intChan := make(chan int, 10)wg.Add(2) // 说明开启了两个线程// 开启了两个协程，writeData和readData应该是交叉执行的go writeData(intChan) // 开启一个协程，往 intChan 中写入数据go readData(intChan)  // 开启一个协程，读取 intChan 的数据wg.Wait()             // 告诉主线程需要等待协程执行完毕fmt.Println("程序执行完毕！")
}func 协程和管道应用2() {// 需求：要求统计1-8000的数字中，哪些是素数// 将统计素数的任务，分配给4个协程去完成intChan := make(chan int, 1000)   // 读写1-8000数字的管道primeChan := make(chan int, 2000) // 存储素数的管道wg.Add(5)                         // 下面开启了5个协程// 开启写入 1-8000 数字的协程go func() {for i := 1; i <= 8000; i++ {intChan <- i}close(intChan)wg.Done()}()// 开启4个读取 1-8000 数字，并统计素数的协程for i := 0; i < 4; i++ {go isPrime(intChan, primeChan)}wg.Wait()        // 等待协程执行完毕close(primeChan) // 关闭 primeChan 管道// 遍历primeChan，把结果取出来for v := range primeChan {fmt.Printf("素数是 = %v\n", v)}
}func 管道注意细节() {intChan := make(chan int, 10)for i := 0; i < 10; i++ {intChan <- i}stringChan := make(chan string, 5)for i := 0; i < 5; i++ {stringChan <- "hello" + fmt.Sprintf("%d", i)}// 传统的方法在遍历管道时，如果不关闭会阻塞而导致 deadlock// 在实际开发中，可能不好确定什么时候关闭管道，这时可以使用select方式解决for {select {// 这里如果intChan一直没有关闭，也不会一直阻塞而导致deadlock// 如果一个case取不到数据，会自动到下一个case中取case v := <-intChan:fmt.Println("从intChan读取的数据=", v)case v := <-stringChan:fmt.Println("从stringChan读取的数据=", v)default:fmt.Println("都取不到了")return}}
}

文件

文件这块没啥好说的，拿到函数直接用就行。需要注意一点就是文件file是一个指针类型。

package mainimport ("bufio""fmt""io""os"
)func main() {//基本使用读()基本使用写()
}func 基本使用读() {// 打开文件file, err := os.Open("C:\\Users\\Administrator\\Desktop\\1.txt")if err != nil {fmt.Println("文件打开错误：", err)}//fmt.Printf("file=%v", file) // 输出的是一个地址defer file.Close() // 当函数退出时，要关闭file，否则会有内存泄露// 创建一个Reader，是带缓冲，默认缓冲区为4096（这种方式比较适合大文件读取）reader := bufio.NewReader(file)for {str, err := reader.ReadString('\n')if err == io.EOF { // io.EOF表示读到了文件末尾，这时就可以退出循环了break}fmt.Print(str)}fmt.Println("文件读取完成")// ioutil.ReaderFile，一次性将文件读取到位 这种方法适合读取比较小的文件// 不过新版本 ioutil.ReadFile 已经弃用了，这个函数其实调用的就是 os.ReadFilecontent, err := os.ReadFile("C:\\Users\\Administrator\\Desktop\\学习计划.txt")if err != nil {fmt.Printf("文件读取失败：%v", err)}//fmt.Println(content) // content是一个 []bytefmt.Println(string(content)) // 所以要转成string}func 基本使用写() {filePath := "C:\\Users\\Administrator\\Desktop\\测试.txt"/*OpenFile 第二个参数：文件打开模式O_RDONLY int = syscall.O_RDONLY // 只读O_WRONLY int = syscall.O_WRONLY // 只写O_RDWR   int = syscall.O_RDWR   // 读写O_APPEND int = syscall.O_APPEND // 追加O_CREATE int = syscall.O_CREAT  // 如果不存在就创建O_EXCL   int = syscall.O_EXCL   // 文件必须不存在O_SYNC   int = syscall.O_SYNC   // 同步ioO_TRUNC  int = syscall.O_TRUNC  // 打开时清空文件（一般用于覆盖写入）第三个参数只作用于linux系统，Windows系统不起作用*/file, err := os.OpenFile(filePath, os.O_WRONLY|os.O_CREATE, 0666)if err != nil {fmt.Printf("文件打开失败：%v", err)}defer file.Close()str := "hello,Golang\n"// NewWriter 带缓冲区的写入，写完之后要用flush刷新。writer := bufio.NewWriter(file)for i := 0; i < 5; i++ {writer.WriteString(str)}writer.Flush()
}

ok，以上就是本篇的全部内容了。下一篇可能是关于网络请求相关的，也有可能是Gorm相关的。

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.rhkb.cn/news/101412.html

如若内容造成侵权/违法违规/事实不符，请联系长河编程网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

chapter 3 Free electrons in solid - 3.2 量子自由电子理论对一些现象的解释

chapter 3 Free electrons in solid - 3.2 量子自由电子理论对一些现象的解释

3.2 自由电子气的热容 Heat capacity of free electron gas 3.2.1 计算自由电子的热容 Calculation of Heat Capacity of free Electrons T>0K, total energy of free electrons: E ∫ E d N 3 5 N e E F 0 [ 1 5 12 π 2 ( k B T E F 0 ) 2 ] E \int EdN \frac{3}{5}…
阅读更多...
econml介绍

econml介绍

EconML简介 EconML: A Python Package for ML-Based Heterogeneous Treatment Effects Estimation EconML是一个通过机器学习方法从观察数据中估计heterogeneous treatment effects的Python包。该软件包是微软研究院ALICE项目的一部分&#xff0c;目的是将最新的机器学习方法…
阅读更多...
CAM实现的流程--基于Pytorch实现

CAM实现的流程--基于Pytorch实现

CAM实现的流程 CAM类激活映射CAM是什么CAM与CNN CAM类激活映射 CAM是什么 可视化CNN的工具&#xff0c; CAM解释网络特征变化&#xff0c;CAM使得弱监督学习发展成为可能&#xff0c;可以慢慢减少对人工标注的依赖&#xff0c;能降低网络训练的成本。通过可视化&#xff0c;就…
阅读更多...
【Axure高保真原型】通过输入框动态控制折线图

【Axure高保真原型】通过输入框动态控制折线图

今天和大家分享通过输入框动态控制折线图的原型模板&#xff0c;在输入框里维护项目数据&#xff0c;可以自动生成对应的折线图&#xff0c;鼠标移入对应折点&#xff0c;可以查看对应数据。使用也非常方便&#xff0c;只需要修改输入框里的数据&#xff0c;或者复制粘贴文本&a…
阅读更多...
泰克MDO3054示波器

泰克MDO3054示波器

MDO3054 泰克MDO3054混合域示波器 优秀的六合一综合示波器&#xff0c;可以全面量身定制&#xff0c;可以全面升级 当今集成设计需要集成度与之相当的示波器&#xff0c;如 MDO3000 混合域示波器 (MDO) 系列。这是一种 6 合 1 示波器之集大成者&#xff0c;集成了一台频谱分…
阅读更多...
CentOS Stream 9中安装MySQL的详细步骤

CentOS Stream 9中安装MySQL的详细步骤

文章目录 卸载MySQL在线安装离线安装忘记密码 卸载MySQL 安装前先卸载系统上旧版本的 MySQL&#xff08;没有则跳过此步骤&#xff09; 查看已安装的MySQLrpm -qa | grep mysql卸载查询到的所有安装包rpm -e PackageName # 可批量删除删除my.cnf 查看/etc/my.cnf文件是否还存…
阅读更多...
SQL 语句继续学习之记录二

SQL 语句继续学习之记录二

三&#xff0c; 聚合与排序 对表进行聚合查询&#xff0c;即使用聚合函数对表中的列进行合计值或者平均值等合计操作。 通常&#xff0c;聚合函数会对null以外的对象进行合计。但是只有count 函数例外&#xff0c;使用count(*) 可以查出包含null在内的全部数据行数。 使用dis…
阅读更多...
网络安全在医疗行业中的重要性

网络安全在医疗行业中的重要性

不可否认&#xff0c;现代世界见证了技术和医疗行业的交织&#xff0c;塑造了我们诊断、治疗和管理健康状况的新方式。随着电子健康记录取代纸质文件&#xff0c;远程医疗缩短了患者和医疗服务提供者之间的距离&#xff0c;数字化转型既是福音&#xff0c;也是挑战。最近的全球…
阅读更多...
7.elasticsearch同步工具-logstah

7.elasticsearch同步工具-logstah

1.logstah Logstash 是一个用于数据处理和转换的开源工具&#xff0c;它可以将来自不同源头的数据收集、转换、过滤&#xff0c;并将其发送到不同的目标。Logstash 是 ELK&#xff08;Elasticsearch、Logstash 和 Kibana&#xff09;技术栈的一部分&#xff0c;通常与 Elastics…
阅读更多...
java版本spring cloud 企业工程系统管理 工程项目管理系统源码em

java版本spring cloud 企业工程系统管理 工程项目管理系统源码em

工程项目管理软件&#xff08;工程项目管理系统&#xff09;对建设工程项目管理组织建设、项目策划决策、规划设计、施工建设到竣工交付、总结评估、运维运营&#xff0c;全过程、全方位的对项目进行综合管理 工程项目各模块及其功能点清单 一、系统管理 1、数据字典&#xff…
阅读更多...
Windows快捷键常用介绍，提高工作（摸鱼）效率

Windows快捷键常用介绍，提高工作（摸鱼）效率

一&#xff1a;背景 本文主要是讲解Windows电脑常见的快捷键&#xff0c;包括ctrl快捷键&#xff0c;win快捷键&#xff0c;不管是开发人员还是普通办公人员&#xff0c;都是很方便的。我们平时没事操作都是用鼠标去选择对应的功能&#xff0c;或者在我的电脑--控制面板寻找&a…
阅读更多...
k8s service (三)

k8s service (三)

K8s service (三) LoadBalancer类型的Service LoadBalancer和NodePort其实是同一种方式&#xff0c;目的都是向外暴露一个端口&#xff0c;区别在于LoadBalancer会在集群的外部再来做一个负载均衡设备&#xff0c;而这个设备需要外部环境支持的&#xff0c;外部服务发送到这…
阅读更多...
Vue的Ajax请求-axios、前后端分离练习

Vue的Ajax请求-axios、前后端分离练习

Vue的Ajax请求 axios简介 ​ Axios&#xff0c;是Web数据交互方式&#xff0c;是一个基于promise [5]的网络请求库&#xff0c;作用于node.js和浏览器中&#xff0c;它是 isomorphic 的(即同一套代码可以运行在浏览器和node.js中)。在服务端它使用原生node.js http模块, 而在…
阅读更多...
FastDFS+Nginx - 本地搭建文件服务器同时实现在外远程访问「端口映射」

FastDFS+Nginx - 本地搭建文件服务器同时实现在外远程访问「端口映射」

文章目录 前言1. 本地搭建FastDFS文件系统1.1 环境安装1.2 安装libfastcommon1.3 安装FastDFS1.4 配置Tracker1.5 配置Storage1.6 测试上传下载1.7 与Nginx整合1.8 安装Nginx1.9 配置Nginx 2. 局域网测试访问FastDFS3. 安装cpolar内网穿透4. 配置公网访问地址5. 固定公网地址5.…
阅读更多...
关于模板的大致认识【C++】

关于模板的大致认识【C++】

文章目录 函数模板函数模板的原理函数模板的实例化模板参数的匹配原则 类模板类模板的定义格式类模板的实例化 非类型模板参数typename 与class模板的特化函数模板特化类模板特化全特化偏特化 模板的分离编译 函数模板 函数模板的原理 template <typename T> //模板参数…
阅读更多...
2023年最佳JavaScript框架：React、Vue、Angular和Node.js的比较

2023年最佳JavaScript框架：React、Vue、Angular和Node.js的比较

文章目录 React&#xff1a;构建用户界面的首选Vue&#xff1a;简单优雅的前端框架Angular&#xff1a;Google支持的全面框架Node.js&#xff1a;服务器端的JavaScript运行环境比较不同框架的优势与劣势React&#xff1a;Vue&#xff1a;Angular&#xff1a;Node.js&#xff1a…
阅读更多...
KaiwuDB CTO 魏可伟：回归用户本位，打造“小而全”的数据库

KaiwuDB CTO 魏可伟：回归用户本位，打造“小而全”的数据库

8月16日&#xff0c;KaiwuDB 受邀亮相第十四届中国数据库技术大会 DTCC 2023。KaiwuDB CTO 魏可伟接受大会主办方的采访&#xff0c;双方共同围绕“数据库架构演进、内核引擎设计以及不同技术路线”展开深度探讨。 以下是采访的部分实录 ↓↓↓ 40 多年前&#xff0c;企业的数…
阅读更多...
Lua之Lua源文件批量转换为luac字节码文件

Lua之Lua源文件批量转换为luac字节码文件

准备的工具&#xff1a;luac.exe CSDNhttps://mp.csdn.net/mp_download/manage/download/UpDetailed Unity版: using System; using System.Collections; using System.Collections.Generic; using System.IO; using UnityEditor; using UnityEngine;public static class Bat…
阅读更多...
Postman 如何进行参数化

Postman 如何进行参数化

前言 Postman作为一款接口测试工具&#xff0c;受到了非常多的开发工程师的拥护。 那么做为测试&#xff0c;了解Postman这款工具就成了必要的了。 这篇文章就是为了解决Postman怎么进行参数化的。 全局变量 全局变量是将这个变量设置成整个程序的都可以用&#xff0c;不用去…
阅读更多...
Coremail参与编制|《信创安全发展蓝皮书——系统安全分册（2023年）》

Coremail参与编制|《信创安全发展蓝皮书——系统安全分册（2023年）》

信创安全发展蓝皮书 近日&#xff0c;Coremail参与编制的《信创安全发展蓝皮书—系统安全分册&#xff08;2023年&#xff09;》重磅发布。 此次信创安全发展蓝皮书由工业和信息化部电子第五研究所联合大数据协同安全技术国家工程研究中心重磅共同发布。 本次蓝皮书涵盖信创系…
阅读更多...
最新文章
推荐文章

Copyright @ 2022~2023

友情链接： 我的编程经验分享 一条长河网 尧图网站开发