Kubernetes

 1func closechan(c *hchan) {
 2	// 关闭一个 nil channel，panic
 3	if c == nil {
 4		panic(plainError("close of nil channel"))
 5	}
 6
 7	// 上锁
 8	lock(&c.lock)
 9	// 如果 channel 已经关闭
10	if c.closed != 0 {
11		unlock(&c.lock)
12		// panic
13		panic(plainError("close of closed channel"))
14	}
15
16	// …………
17
18	// 修改关闭状态
19	c.closed = 1
20
21	var glist *g
22
23	// 将 channel 所有等待接收队列的里 sudog 释放
24	for {
25		// 从接收队列里出队一个 sudog
26		sg := c.recvq.dequeue()
27		// 出队完毕，跳出循环
28		if sg == nil {
29			break
30		}
31
32		// 如果 elem 不为空，说明此 receiver 未忽略接收数据
33		// 给它赋一个相应类型的零值
34		if sg.elem != nil {
35			typedmemclr(c.elemtype, sg.elem)
36			sg.elem = nil
37		}
38		if sg.releasetime != 0 {
39			sg.releasetime = cputicks()
40		}
41		// 取出 goroutine
42		gp := sg.g
43		gp.param = nil
44		if raceenabled {
45			raceacquireg(gp, unsafe.Pointer(c))
46		}
47		// 相连，形成链表
48		gp.schedlink.set(glist)
49		glist = gp
50	}
51
52	// 将 channel 等待发送队列里的 sudog 释放
53	// 如果存在，这些 goroutine 将会 panic
54	for {
55		// 从发送队列里出队一个 sudog
56		sg := c.sendq.dequeue()
57		if sg == nil {
58			break
59		}
60
61		// 发送者会 panic
62		sg.elem = nil
63		if sg.releasetime != 0 {
64			sg.releasetime = cputicks()
65		}
66		gp := sg.g
67		gp.param = nil
68		if raceenabled {
69			raceacquireg(gp, unsafe.Pointer(c))
70		}
71		// 形成链表
72		gp.schedlink.set(glist)
73		glist = gp
74	}
75	// 解锁
76	unlock(&c.lock)
77
78	// Ready all Gs now that we've dropped the channel lock.
79	// 遍历链表
80	for glist != nil {
81		// 取最后一个
82		gp := glist
83		// 向前走一步，下一个唤醒的 g
84		glist = glist.schedlink.ptr()
85		gp.schedlink = 0
86		// 唤醒相应 goroutine
87		goready(gp, 3)
88	}
89}