详解Golang中Channel的高级用法_Golang

在阅读k8s的源代码中，发现了一些比较有意思的用法。

在go语言中，chan（通道）是一种用于在不同的goroutine之间进行通信的机制。waitforcachesync(stopch <-chan struct{}) error方法中的参数stopch <-chan struct{}表示一个只读的通道，用于接收停止信号。

通道的基本概念

通道（channel）：通道是go语言中的一种数据结构，用于在不同的goroutine之间传递数据。通道可以是无缓冲的（同步的）或有缓冲的（异步的）。
只读通道：<-chan t表示一个只读通道，意味着你只能从这个通道中接收数据，而不能向这个通道发送数据。
只写通道：chan<- t表示一个只写通道，意味着你只能向这个通道发送数据，而不能从这个通道接收数据。

waitforcachesync 方法中的 stopch

waitforcachesync 方法通常用于等待缓存（如kubernetes中的informer缓存）同步完成。stopch参数是一个只读通道，用于接收停止信号，以便在需要时中断等待过程。

参数解释

stopch <-chan struct{}：这是一个只读的通道，类型为struct{}。struct{}是一种零大小的结构体类型，通常用于表示信号或事件，因为它不占用任何内存。

使用场景

停止信号：stopch通道通常用于接收停止信号。当你向这个通道发送一个值时，表示你希望停止当前的操作。
协程间通信：通过stopch通道，不同的goroutine可以协调工作。例如，一个goroutine可以等待缓存同步完成，而另一个goroutine可以在需要时发送停止信号。

示例代码

以下是一个简单的示例，展示了如何使用stopch通道来控制waitforcachesync方法的执行：

package main
 
import (
	"fmt"
	"time"
)
 
// waitforcachesync 模拟等待缓存同步的方法
func waitforcachesync(stopch <-chan struct{}) error {
	fmt.println("waiting for cache to sync...")
 
	select {
	case <-time.after(5 * time.second):
		fmt.println("cache synced successfully.")
		return nil
	case <-stopch:
		fmt.println("received stop signal, stopping cache sync.")
		return fmt.errorf("cache sync stopped")
	}
}
 
func main() {
	stopch := make(chan struct{})
 
	// 启动一个goroutine来等待缓存同步
	go func() {
		err := waitforcachesync(stopch)
		if err != nil {
			fmt.println("error:", err)
		}
	}()
 
	// 模拟一些工作
	time.sleep(2 * time.second)
 
	// 发送停止信号
	close(stopch)
 
	// 等待一段时间以便观察输出
	time.sleep(3 * time.second)
}

代码解释

定义waitforcachesync方法：

func waitforcachesync(stopch <-chan struct{}) error {
    fmt.println("waiting for cache to sync...")
 
    select {
    case <-time.after(5 * time.second):
        fmt.println("cache synced successfully.")
        return nil
    case <-stopch:
        fmt.println("received stop signal, stopping cache sync.")
        return fmt.errorf("cache sync stopped")
    }
}

- 使用select语句等待两个事件：缓存同步完成（模拟为5秒后）或接收到停止信号。
- 如果接收到停止信号，返回一个错误。
在main函数中使用stopch通道：

func main() {
    stopch := make(chan struct{})
 
    // 启动一个goroutine来等待缓存同步
    go func() {
        err := waitforcachesync(stopch)
        if err != nil {
            fmt.println("error:", err)
        }
    }()
 
    // 模拟一些工作
    time.sleep(2 * time.second)
 
    // 发送停止信号
    close(stopch)
 
    // 等待一段时间以便观察输出
    time.sleep(3 * time.second)
}