记一次协程泄漏bug

先看代码片段,项目使用gf;比较熟悉gf得童鞋应该可以直接看到bug

// 定时执行任务
gtimer.Add(time.Duration(second)*time.Second, func() {
    // ConnMap 为gf中得gmap，此处是遍历
    ConnMap.Iterator(func(k interface{}, v interface{}) bool {
        deviceid := k.(string)
        if conn, ok := v.(*gtcp.Conn); ok {

            msg := Message{
                HEADER: Header{
                    MID:     CMD_NOP,
                },
                BODY: []byte{},
            }
            b := Packer(msg)
            err := conn.Send(b)
            if err != nil {

                glog.Error(err)
                ConnMap.Remove(deviceid)
                conn.Close()

                return true
            }
            return true
        }
        glog.Error("ConnMap转换错误")
        return true
    })
})

解析

gf中gmap是封装好支持并发的map，原因就在这里，map想要并发需要一些lock支持。打开源码可看到

// Iterator iterates the hash map readonly with custom callback function <f>.
// If <f> returns true, then it continues iterating; or false to stop.
func (m *AnyAnyMap) Iterator(f func(k interface{}, v interface{}) bool) {
    m.mu.RLock()
    defer m.mu.RUnlock()
    for k, v := range m.data {
        if !f(k, v) {
            break
        }
    }
}

// Remove deletes value from map by given <key>, and return this deleted value.

func (m *AnyAnyMap) Remove(key interface{}) (value interface{}) {

    m.mu.Lock()

     if m.data !=  nil {

     var ok bool

     if value, ok = m.data[key]; ok {

     delete(m.data, key)

            }

        }

    m.mu.Unlock()

 return

}

在我执行定时任务遍历时会有一个判断，tcp是否关闭或有问题，关闭我会删除gmap中得键值对。
遍历时，有一个读写锁，然后删除时有一个互斥锁，执行到那里就会导致死锁。

笔记

go读写锁:
读写锁可以让多个读操作并发，同时读取，但是对于写操作是完全互斥的，也就是说，当一个goroutinue进行写操作时，其他goroutine既不能进行读操作，也不能进行写操作。
1:读锁可以被任意多个读goroutine持有，当一个goroutine获取读锁后，其他goroutine也可以获取到读锁，但如果这时候有goroutine尝试获取写锁，则获取写锁的线程将会被阻塞，这时候如果再有goroutine尝试获取读锁，则也会被阻塞。
2:当一个goroutine获取写锁后，其他获取读锁/写锁的线程都会被阻塞。
3:读锁是可重入锁，同一个goroutine可以多次获取读锁。同理，当一个线程获取到了写锁后尝试获取读锁，会造成死锁错误。

读写锁跟互斥锁的区别:
读写锁相比互斥锁来说，锁的粒度有所减少，这是因为读写锁可以让多个读取共享资源的goroutine同时获取读锁，而互斥锁来说，即使是多个读取共享资源的goroutine，也只有一个可以获取锁，其他的都会被阻塞。

参考链接：blog.csdn.net/yanghaitao5000/artic...