【Go自学版】02-goroutine

news2025/11/4 10:37:50

在这里插入图片描述
利用时间片分割进程，致使宏观上A,B,C同时执行（并发）

在这里插入图片描述
CPU利用率包含了执行和切换，进程/线程的数量越多，切换成本也会增大

在这里插入图片描述

在这里插入图片描述
最大并行数：GOMAXPROCS

work stealing: 偷其他队列的G
hand off: 当前G1阻塞，创建/唤醒一个thread，移动当前本地队列至其上

func newTask() {
	i := 0
	for {
		i++
		fmt.Printf("new Goroutine: i = %d\n", i)
		time.Sleep(1 * time.Second)
	}
}

func main() {
	/*
	go newTask()
	i := 0
	for {
		i++
		fmt.Printf("main Goroutine: i = %d\n", i)
		time.Sleep(1 * time.Second)
	}
	*/
	go func() {
		defer fmt.Println("A.defer")

		func() {
			defer fmt.Println("B.defer")
			
			runtime.Goexit() // 退出Goroutine
			
			fmt.Println("B")
		}()

		fmt.Println("A")
	}()
	for {
		time.Sleep(1 * time.Second)
	}
}

在这里插入图片描述

// channel
func main() {
	// 无缓存
	c := make(chan int)

	go func() {
		defer fmt.Println("goroutine end")
		fmt.Println("goroutine running")
		c <- 114514 // 114514 发送到 c
	}()

	num := <-c // c 中接收数据并赋值给num
	fmt.Printf("num = %d\n", num)
	fmt.Println("main goroutine end")
}

在这里插入图片描述

func main() {
	// 有缓存
	c := make(chan int, 3)
	fmt.Println("len(c) = ", len(c), ", cap(c) = ", cap(c))

	go func() {
		defer fmt.Println("子go结束")
		for i := 0; i < 3; i++ {
			c <- i
			fmt.Println("子go正在运行：len(c) = ", len(c), "cap(c) = ", cap(c))
			fmt.Println("发送元素 = ", i)
		}
	}()

	time.Sleep(2 * time.Second)

	for i := 0; i < 3; i++ {
		num := <-c
		fmt.Println("num = ", num)
	}

	fmt.Println("main 结束")

}