io.Pipe Write（）和Read（）函数如何工作？

Question

通过阅读golang src pipe.go来弄清楚管道是如何工作的，我跑到这两个write（）函数中去了（）&。令我困惑的是，如果读者调用read（）func并保存l.lock然后等待数据，那么writer如何调用write（）func并获取l.lock来写入数据？

func (p *pipe) write(b []byte) (n int, err error) { 
    // pipe uses nil to mean not available 
    if b == nil { 
     b = zero[:] 
    } 

    // One writer at a time. 
    p.wl.Lock() 
    defer p.wl.Unlock() 

    p.l.Lock() 
    defer p.l.Unlock() 
    if p.werr != nil { 
     err = ErrClosedPipe 
     return 
    } 
    p.data = b 
    p.rwait.Signal() 
    for { 
     if p.data == nil { 
      break 
     } 
     if p.rerr != nil { 
      err = p.rerr 
      break 
     } 
     if p.werr != nil { 
      err = ErrClosedPipe 
      break 
     } 
     p.wwait.Wait() 
    } 
    n = len(b) - len(p.data) 
    p.data = nil // in case of rerr or werr 
    return 
} 

和读：

func (p *pipe) read(b []byte) (n int, err error) { 

    // One reader at a time. 
    p.rl.Lock() 
    defer p.rl.Unlock() 

    p.l.Lock() 
    defer p.l.Unlock() 
    for { 
     if p.rerr != nil { 
      return 0, ErrClosedPipe 
     } 
     if p.data != nil { 
      break 
     } 
     if p.werr != nil { 
      return 0, p.werr 
     } 
     p.rwait.Wait() 
    } 
    n = copy(b, p.data) 
    p.data = p.data[n:] 
    if len(p.data) == 0 { 
     p.data = nil 
     p.wwait.Signal() 
    } 
    return 
} 

Answer 1

互斥p.l在读取用于写sync.Cond条件，这将锁定并根据需要解锁。

调用Wait解锁其锁，并等待相应的Signal调用。您可以看到管道使用p.wwait和p.rwait来协调Read和Write方法中的读者和作者。