全局变量定义

atomic.CompareAndSwapInt64(startLoc,

start,

以确保线程安全atomic.StoreInt32(valid,

1)return}}return}}

time.Since(startTime)fmt.Printf(程序运行时间:

%s\n,

atomic.CompareAndSwapInt64(startLoc,

start,

以确保线程安全atomic.StoreInt32(valid,

1)return}}}}

time.Since(startTime)fmt.Printf(程序运行时间:

%s\n,

Context而TODO()创建的通常被认为是暂时的、未确定的

func

!reflectlite.TypeOf(key).Comparable()

{panic(key

抛出异常父Ctx具有超时时间且比设置的超时时间更早结束则新建CancelCtx加入父Ctx监听列表且返回该新建CancelCtx。

设置新的包含超时时间的timerCtx内部继承了cancelCtx结构体加入父Ctx的监听列表检查是否已经超时

超时则取消该上下文

d,}c.cancelCtx.propagateCancel(parent,

c)dur

的核心目的是将父上下文的取消信号及其取消原因传递给子上下文。

不同的父上下文类型如

*cancelCtx

则无需监听父Ctx设置了回调函数父Ctx类型是*cancelCtx则把子Ctx加入自身map中每个子Ctx都会开启协程监听父Ctx信号同步取消自身。

func

Cause(parent))returndefault:}if

{//

make(map[canceler]struct{})}p.children[child]

struct{}{}}p.mu.Unlock()return}if

{//

stop,}c.mu.Unlock()return}goroutines.Add(1)go

func()

-parent.Done():child.cancel(false,

parent.Err(),

在有缓冲区的channel部分数据使用环形链表进行存储存储有变量记录有效数据区域。

type

同时分为有缓冲区和无缓冲区两种前者是异步的在缓冲区未满时可以持续输入不会阻塞直到缓冲区满后者则为有goroutine输入等待有协程进行数据消费否则持续阻塞。

参考链接

https://www.cnblogs.com/Paul-watermelon/articles/17484439.html

Channel