golang goroutine 机制

Go 语言的 goroutine 是一种非常轻量级的线程，由 Go 运行时管理。goroutine 的设计目的是让开发者能够以并发的方式执行任务，而不需要直接管理线程。以下是 goroutine 机制的一些关键点：

1. 轻量级：goroutine 比传统的操作系统线程更加轻量级，因为它们在用户态管理，而不是由操作系统内核管理。

2. 并发执行：goroutine 可以并发执行，这意味着它们可以同时运行，从而提高程序的执行效率。

3. 共享内存：goroutines 共享同一个进程的内存空间，这意味着它们可以直接访问相同的数据结构，但这也意味着需要考虑数据竞争和同步问题。

4. 通信：goroutines 之间的通信主要通过 channels 来实现。channels 是 Go 语言中的一种同步机制，用于在 goroutines 之间安全地传递数据。

5. 创建：创建一个新的 goroutine 非常简单，只需要在函数调用前加上 go 关键字即可。

6. 调度：goroutine 的调度是由 Go 运行时管理的，开发者不需要手动调度。

7. 栈：每个 goroutine 都有自己的栈，初始大小为几千字节，但可以根据需要动态扩展。

8. 选择性阻塞：goroutine 可以在某些操作（如 I/O 操作或 channel 操作）上阻塞，但这种阻塞是选择性的，不会阻塞整个程序。

9. 错误处理：goroutine 之间的错误处理需要特别注意，因为一个 goroutine 的崩溃不会直接影响到其他 goroutine。

10. 等待：可以使用 sync.WaitGroup 或者 context.Context 来等待一组 goroutines 完成它们的任务。

下面是一个简单的示例，展示了如何创建和使用 goroutine：

package main

import (
	"fmt"
	"time"
)

func say(s string, c chan string) {
	for i := 0; i < 5; i++ {
		time.Sleep(time.Second)
		c <- fmt.Sprintf("%s %d", s, i)
	}
	close(c)
}

func main() {
	c := make(chan string)
	go say("hello", c)  // 启动一个新的 goroutine
	go say("world", c)  // 启动另一个 goroutine

	// 等待并打印从两个 goroutine 发送的消息
	for msg := range c {
		fmt.Println(msg)
	}
}

在这个示例中，say 函数被两次调用，每次都会启动一个新的 goroutine。每个 goroutine 都会向 channel c 发送消息，而主 goroutine 则等待并打印这些消息。这个程序展示了 goroutine 的并发执行和通信机制。