对Go语言中的context包源码分析_Golang_

    func WithCancel(parent Context) (ctx Context, cancel CancelFunc)     func WithDeadline(parent Context, d time.Time) (Context, CancelFunc)     func WithTimeout(parent Context, timeout time.Duration) (Context, CancelFunc)     type CancelFunc     type Context

 type Context interface {       Deadline() (deadline time.Time, ok bool)       Done() <-chan struct{}       Err() error       Value(key interface{}) interface{}     }

  type emptyCtx int     func (*emptyCtx) Deadline() (deadline time.Time, ok bool) { return }     func (*emptyCtx) Done() <-chan struct{} { return nil }     func (*emptyCtx) Err() error { return nil }     func (*emptyCtx) Value(key interface{}) interface{} { return nil }     func (e *emptyCtx) String() string {       switch e {       case background:         return "context.Background"       case todo:         return "context.TODO"       }       return "unknown empty Context"     }

    var (       background = new(emptyCtx)       todo       = new(emptyCtx)     )     func Background() Context {       return background     }     func TODO() Context {       return todo     }

type cancelCtx struct {   Context   mu       sync.Mutex   done     chan struct{}   children map[canceler]struct{}   err      error }

  var cancelCtxKey int     func (c *cancelCtx) Value(key interface{}) interface{} {       if key == &cancelCtxKey {         return c       }       return c.Context.Value(key)     }     func (c *cancelCtx) Done() <-chan struct{} {       c.mu.Lock()       if c.done == nil {         c.done = make(chan struct{})       }       d := c.done       c.mu.Unlock()       return d     }     func (c *cancelCtx) Err() error {       c.mu.Lock()       err := c.err       c.mu.Unlock()       return err     }

    func contextName(c Context) string {       if s, ok := c.(stringer); ok {         return s.String()       }       return reflectlite.TypeOf(c).String()     }     func (c *cancelCtx) String() string {       return contextName(c.Context) + ".WithCancel"     }

   var closedchan = make(chan struct{})     func init() {       close(closedchan)     }     func (c *cancelCtx) cancel(removeFromParent bool, err error) {       if err == nil {         panic("context: internal error: missing cancel error")       }       c.mu.Lock()       if c.err != nil {         c.mu.Unlock()         return // already canceled       }       c.err = err       if c.done == nil {         c.done = closedchan       } else {         close(c.done)       }       for child := range c.children {         // NOTE: acquiring the child's lock while holding parent's lock.         child.cancel(false, err)       }       c.children = nil       c.mu.Unlock()       if removeFromParent {         removeChild(c.Context, c)       }     }

    func parentCancelCtx(parent Context) (*cancelCtx, bool) {       done := parent.Done()       if done == closedchan || done == nil {         return nil, false       }       p, ok := parent.Value(&cancelCtxKey).(*cancelCtx)       if !ok {         return nil, false       }       p.mu.Lock()       ok = p.done == done       p.mu.Unlock()       if !ok {         return nil, false       }       return p, true     }     func removeChild(parent Context, child canceler) {       p, ok := parentCancelCtx(parent)       if !ok {         return       }       p.mu.Lock()       if p.children != nil {         delete(p.children, child)       }       p.mu.Unlock()     }

type canceler interface {   cancel(removeFromParent bool, err error)   Done() 
                
提示：
                    本文由神整理自网络，如有侵权请联系本站删除！
                    

                    本站声明： 

                    1、本站所有资源均来源于互联网，不保证100%完整、不提供任何技术支持； 

                    2、本站所发布的文章以及附件仅限用于学习和研究目的;不得将用于商业或者非法用途；否则由此产生的法律后果，本站概不负责！
                
                

                

                                            
上一篇：Go interface{} 转切片类型的实现方法_Golang_
                                                                
下一篇：golang数组和切片作为参数和返回值的实现_Golang_