标准库的 sync.Pool 之所以要维护这么一个 allPools 意图也比较容易推测，主要是为了 GC 的时分对 pool 停止清算，这也就是为什么说运用 sync.Pool 做对象池时，其中的对象活不过一个 GC 周期的缘由。sync.Pool 本身也是为了处置少量生成暂时对象对 GC 形成的压力成绩。
说完了流程，成绩也就比较清楚了，每一个用户央求最终都需求去抢一把全局锁，高并发场景下全局锁是大忌。但是这个全局锁是由于开源库直接带来的全局锁成绩，经过看本人的代码并不是那么容易发现。
知道了成绩，改良方案其实也还好完成，第一是可以修正开源库，将 template 的 sync.Pool 作为全局对象来援用，这样大部分 pool.Get 不会走到 pinSlow 流程。第二是对 fasttemplate.Template 对象停止复用，道理也是一样的，就不会有那么多的 sync.Pool 对象生成了。但前面也提到了，这个是个直接成绩，假设开发任务忙碌，不太能够一切的依赖库把代码全看完之后再运用，这种状况下怎样避免线上的缺点呢?
压测尽量早做呗。
metrics 上报和 log 锁
这两个本质都是一样的成绩，就放在一同了。
公司之前 metrics 上报 client 都是基于 udp 的，大少数做的复杂粗犷，就是一个 client，用户传什么就写什么，最终一定会走到：
func (c *UDPConn) WriteToUDP(b []byte, addr *UDPAddr) (int, error) {
---------- 刨去无用细节
n, err := c.writeTo(b, addr)
---------- 刨去无用细节
return n, err
}
或许是：
func (c *UDPConn) WriteTo(b []byte, addr Addr) (int, error) {
---------- 刨去无用细节
n, err := c.writeTo(b, a)
---------- 刨去无用细节
return n, err
}
调用的是：
func (c *UDPConn) writeTo(b []byte, addr *UDPAddr) (int, error) {
---------- 刨去无用细节
return c.fd.writeTo(b, sa)
}
然后：
func (fd *netFD) writeTo(p []byte, sa syscall.Sockaddr) (n int, err error) {
n, err = fd.pfd.WriteTo(p, sa)
runtime.KeepAlive(fd)
return n, wrapSyscallError("sendto", err)
}
然后是：
func (fd *FD) WriteTo(p []byte, sa syscall.Sockaddr) (int, error) {
if err := fd.writeLock(); err != nil { =========> 重点在这里
return 0, err
}
defer fd.writeUnlock()
for {
err := syscall.Sendto(fd.Sysfd, p, 0, sa)
if err == syscall.EAGAIN && fd.pd.pollable() {
if err = fd.pd.waitWrite(fd.isFile); err == nil {
continue
}
}
if err != nil {
return 0, err
}
return len(p), nil
}
}
本质上，就是在高成本的网络操作上套了一把大的写锁，异样在高并发场景下会招致少量的锁抵触，进而招致少量的 Goroutine 堆积和接口延迟。
异样的，知道了成绩，处置办法也很复杂。再看看日志相关的。由于公司目前大部分日志都是直接向文件系统写，本质上同一个时辰操作的是同一个文件，最终都会走到：
func (f *File) Write(b []byte) (n int, err error) {
n, e := f.write(b)
return n, err
}
func (f *File) write(b []byte) (n int, err error) {
n, err = f.pfd.Write(b)
runtime.KeepAlive(f)
return n, err
}
然后：
func (fd *FD) Write(p []byte) (int, error) {
if err := fd.writeLock(); err != nil { =========> 又是 writeLock
return 0, err
}
defer fd.writeUnlock()
if err := fd.pd.prepareWrite(fd.isFile); err != nil {
return 0, err
}
var nn int
for {
----- 略去不相关内容
n, err := syscall.Write(fd.Sysfd, p[nn:max])
----- 略去无用内容
}
}
和 UDP 网络 FD 一样有 writeLock，在系统打日志打得很多的状况下，这个 writeLock 会招致和 metrics 上报一样的成绩。
总结
(责任编辑：admin)