在goroutine中调用C.malloc/C.free时发生内存泄漏

小伙伴们有没有觉得学习Golang很有意思？有意思就对了！今天就给大家带来《在goroutine中调用C.malloc/C.free时发生内存泄漏》，以下内容将会涉及到，若是在学习中对其中部分知识点有疑问，或许看了本文就能帮到你！

当我使用以下简单程序查看 rss 时，我发现持续存在内存泄漏：

package main

/*
#include 
*/
import "C"

import (
    "time"
    "unsafe"
    )

func loopStuff() {
    for {
        ptrs := make([]unsafe.Pointer, 20)
        for i:=0; i<20; i++ {
            ptrs[i] = C.malloc(16 * (1 << i))
        }
        time.Sleep(1 * time.Millisecond)
        for i:=0; i<20; i++ {
            C.free(ptrs[i])
        }
    }
}

func main() {
    for i:=0; i<10; i++ {
        go loopStuff()
    }
    loopStuff()
}

我使用的是 go 1.13.4 和 ubuntu 18.04。 这是怎么回事？

解决方案

我认为问题在于 for {} 循环，它为每个 10+1 goroutine 无限期地运行。

此外，如果您了解 free：

deallocates the space previously allocated by malloc(), calloc(), aligned_alloc(), (since c11) or realloc().

所以它基本上会释放空间，并且不一定立即将内存返回给操作系统。另外，请阅读此 answer。

由于 for loop 无限期地运行，您肯定会看到内存增加，但这并不是泄漏。我通过删除 for 循环 修改了您的代码。然后我使用 bsd 的 top 检查了 rss，它使用的平均值为 1100kb，并且没有上升。也许等待一段时间后，它甚至会减少（当内存返回给操作系统时）。

测试使用：操作系统：macos，go：1.15

bsd 的 top 输出：

pid    command      %cpu time     #th  #wq  #por mem   purg cmpr pgrp  ppid  state
30767  cgo          0.0  00:00.00 11   0    20   1144k 0b   0b   30767 29146 sleeping

代码：

package main

// #include 
import "c"

import "unsafe"

func loopstuff() {
        ptrs := make([]unsafe.pointer, 20)
        for i := 0; i < 20; i++ {
                ptrs[i] = c.malloc(16 * (1 << i))
        }
        for i := 0; i < 20; i++ {
                c.free(ptrs[i])
        }
}

func main() {
        for i := 0; i < 10; i++ {
                go loopstuff()
        }
        loopstuff()
        // block the main goroutine
        select {}
}

更新：

尝试以下代码。每次迭代中肯定都会分配 unsafe.pointer 的切片。还做了一些更改。也许在您的系统上您现在不会看到内存泄漏。

package main

/*
#include 
*/
import "C"

import (
        "time"
        "unsafe"
)

func loopStuff() {
        ptrs := make([]*unsafe.Pointer, 20)
        for {
                for i := 0; i < 20; i++ {
                        tmp := C.malloc(16 * (1 << i))
                        ptrs[i] = &tmp
                }
                time.Sleep(1 * time.Millisecond)
                for i := 0; i < 20; i++ {
                        C.free(*ptrs[i])
                }
        }
}

func main() {
        for i := 0; i < 10; i++ {
                go loopStuff()
        }
        loopStuff()
}

文中关于的知识介绍，希望对你的学习有所帮助！若是受益匪浅，那就动动鼠标收藏这篇《在goroutine中调用C.malloc/C.free时发生内存泄漏》文章吧，也可关注golang学习网公众号了解相关技术文章。