線程創(chuàng)建子線程，線程退出時，釋放了內(nèi)存，但是TOP中只看到有一般的內(nèi)存被釋放了

korpus

架構(gòu)是這樣的。

主進(jìn)程先初始化了一個線程池A，當(dāng)其中一個線程接收到任務(wù)的時候，就會去創(chuàng)建幾個子線程B來處理任務(wù)。（該A1線程使用pthread_jion等待子線程B退出，子線程用pthread_exit退出）。在子線程B中，使用了malloc函數(shù)連續(xù)分配了2段內(nèi)存。任務(wù)處理完后，在退出pthread_exit前，釋放他們。

其中的異�，F(xiàn)象是這樣的，如果我在子線程B中加了日志打印的函數(shù)，那么所有子線程退出時，上面申請的兩個連續(xù)內(nèi)存有一半的大小在top中顯示為未釋放（實際上，已經(jīng)釋放了，我向那2段內(nèi)存中memcpy程序core了）。如果我在子線程B中不加日志打印函數(shù)，就不會有這個現(xiàn)象。

日志打印函數(shù)，檢查過，沒有什么問題。

1. 
   
2. #define LOG_INFO        Log_SysInfo(LOG_LEVEL_INFO,__FILE__,__LINE__),Log_Msg
   
3. 
   
4. void Log_SysInfo(const int iLogLevel, const char *pszFileName, const int iNum)
   
5. {
   
6.     int i = 0;
   
7.     char szLogTime[30];
   
8. 
   
9.     //  加一個寫日志的線程鎖
   
10.     pthread_mutex_lock(&g_WriteLog);
    
11. 
    
12.     memset(szLogTime, 0, sizeof(szLogTime));
    
13.     memset(g_szLogHead, 0, sizeof(g_szLogHead));
    
14. 
    
15.     g_iLogLevel = iLogLevel;
    
16. 
    
17.     //  如果設(shè)置的日志級別小直接返回
    
18.     if(g_iSetLogLevel < g_iLogLevel)
    
19.     {
    
20.         return;
    
21.     }
    
22. 
    
23.     Log_Check();
    
24. 
    
25.     timev_GetLogTime(szLogTime);
    
26.     snprintf(g_szLogHead, sizeof(g_szLogHead), "%s %s L=%d T=%ld E=%d ", szLogTime, pszFileName,
    
27.                  iNum, pthread_self(), errno);
    
28. 
    
29.     switch(iLogLevel)
    
30.     {
    
31.         case LOG_LEVEL_ERROR:
    
32.              sprintf(g_szLogHead + strlen(g_szLogHead), "%s", "[ERROR] ");
    
33.              break;
    
34.         case LOG_LEVEL_WARN:
    
35.              sprintf(g_szLogHead + strlen(g_szLogHead), "%s", "[WARN] ");
    
36.              break;
    
37.         case LOG_LEVEL_DEBUG:
    
38.              sprintf(g_szLogHead + strlen(g_szLogHead), "%s", "[DEBUG] ");
    
39.              break;
    
40.         case LOG_LEVEL_INFO:
    
41.              sprintf(g_szLogHead + strlen(g_szLogHead), "%s", "[INFO] ");
    
42.              break;
    
43.         case LOG_LEVEL_ALL:
    
44.              sprintf(g_szLogHead + strlen(g_szLogHead), "%s", "[ALL] ");
    
45.              break;
    
46.         default:
    
47.              break;
    
48.     }
    
49. }
    
50. 
    
51. void Log_Msg(const char *format, ...)
    
52. {
    
53.     FILE *fp;
    
54.     va_list args;
    
55.     int  olderrno;
    
56.     //char szContext[1024*10];    //  分配10K的臨時變量空間,如果用內(nèi)存分配會不會影響性能
    
57.     int i;
    
58. 
    
59.     //  如果設(shè)置的日志級別小,則直接返回
    
60.     if(g_iSetLogLevel < g_iLogLevel)
    
61.     {
    
62.         pthread_mutex_unlock(&g_WriteLog);
    
63.         return;
    
64.     }
    
65.     olderrno = errno;     
    
66.     //memset(szContext, 0, sizeof(szContext));
    
67. 
    
68.     if(NULL != (fp = fopen(g_szLogFile, "a+")))
    
69.     {
    
70.         fprintf(fp, "%s", g_szLogHead);
    
71.         va_start(args, format);
    
72. //        fprintf(fp, "%s\n", szContext);
    
73.         vfprintf(fp, format, args);
    
74. //        fflush(fp);
    
75.         va_end(args);
    
76.         fprintf(fp, "%s", "\n");
    
77.         fclose(fp);
    
78.     }
    
79.     else
    
80.     {
    
81.         printf("fopen error, errno=%d, file=%s\n", errno, g_szLogFile);
    
82.         perror("fopen");
    
83.         //printf("context1 [%s], file[%s:%d] \n", szContext, __FILE__, __LINE__);
    
84.     }
    
85.     errno = olderrno;
    
86. 
    
87.     pthread_mutex_unlock(&g_WriteLog);
    
88. }

復(fù)制代碼

korpus

這個是子線程的代碼，就算是這樣，先連續(xù)申請兩段內(nèi)存，然后釋放，top中顯示就沒有釋放完。  如果我在pReadMemory申請后，再釋放，pWriteMemory申請后，再釋放就是正常的。搞不懂是什么意思，求大哥大姐幫幫忙！

1. void *trans_SingleThread(void *pData)
   
2. {
   
3.     int iRet;
   
4.     MultTransData *pMultTransData = (MultTransData *)pData;
   
5.     MMapData *pMMapData = NULL;
   
6.     ListNode *pTemp = NULL;
   
7.     void *pReadMemory = NULL;
   
8.     void *pWriteMemory = NULL;
   
9.     MMapData *pFirstSection = NULL;
   
10. 
    
11.     pTemp = pMultTransData->m_pMMapDataList;
    
12.     pFirstSection = (MMapData *)pTemp->pData;
    
13. 
    
14. 
    
15.     //  為寫空間分配內(nèi)存地址
    
16.     pWriteMemory = ufs_MallocMemory(pFirstSection->m_lWriteTotalSize);
    
17.     if(NULL == pWriteMemory)
    
18.     {
    
19.         LOG_ERROR("Malloc Memory Failure!");
    
20.         ufs_vFreeNormalMemory(&pReadMemory);
    
21.         iRet = RT_FAILURE;
    
22.         pthread_exit((void *)&iRet);
    
23.     }
    
24. 
    
25.     //  為讀空間分配內(nèi)存地址
    
26.     pReadMemory = ufs_MallocMemory(pFirstSection->m_lReadTotalSize);
    
27.     if(NULL == pReadMemory)
    
28.     {
    
29.         LOG_ERROR("Malloc Memory Failure!");
    
30.         iRet = RT_FAILURE;
    
31.         pthread_exit((void *)&iRet);
    
32.     }
    
33. 
    
34. 
    
35. LOG_DEBUG("Thread Will Quit");
    
36. 
    
37. ufs_vFreeNormalMemory(&pReadMemory);
    
38. ufs_vFreeNormalMemory(&pWriteMemory);
    
39. 
    
40. 
    
41. 
    
42. pthread_exit((void *)&iRet);
    
43. 
    
44. }

復(fù)制代碼

korpus

求幫助！有沒有哪個可以幫忙看看呢

gaojl0728

回復(fù) 3# korpus


    1. 能不能把LOG_DEBUG的代碼貼出來。
2. 你是看top的哪一個字段？
3. 你說“我向那2段內(nèi)存中memcpy程序core了”， 什么叫core了， 是crash了嗎？
4. crash了， 不一定能證明就是釋放了， 把memcpy的代碼貼出來

korpus

回復(fù) 4# gaojl0728


    你好，謝謝你的關(guān)注，
1 LOG_DEBUG，貼出來了 ，就在第一個代碼里面的
2 top的res字段
3 意思好像沒有表達(dá)清楚，意思是，在我free那2段內(nèi)存后，為了檢查是否真的釋放了，然后向釋放的內(nèi)存memcpy內(nèi)容，然后程序crash了
4 memcpy(pReadMemory, "12345", 5);

gaojl0728

1. 你第一行貼的是LOG_INFO， 我想看看LOG_DEBUG。
2. ufs_vFreeNormalMemory傳遞的為什么是雙重指針，難道會把參數(shù)設(shè)置為NULL?
如果是寫NULL的話，你就不需要memcpy測試了， 直接看看是不是NULL就行了
3. 能不能把ufs_MallocMemory和ufs_vFreeNormalMemory的代碼貼出來看看？
如果實現(xiàn)是用的malloc和free, 那內(nèi)存可能被glibc的內(nèi)存池回收了，并沒有還給內(nèi)核。把代碼貼出來看看吧
4. pFirstSection->m_lWriteTotalSize和pFirstSection->m_lReadTotalSize的大小多少？

gaojl0728

回復(fù) 5# korpus


    1. 你第一行貼的是LOG_INFO， 我想看看LOG_DEBUG。
2. ufs_vFreeNormalMemory傳遞的為什么是雙重指針，難道會把參數(shù)設(shè)置為NULL?
如果是寫NULL的話，你就不需要memcpy測試了， 直接看看是不是NULL就行了
3. 能不能把ufs_MallocMemory和ufs_vFreeNormalMemory的代碼貼出來看看？
如果實現(xiàn)是用的malloc和free, 那內(nèi)存可能被glibc的內(nèi)存池回收了，并沒有還給內(nèi)核。把代碼貼出來看看吧
4. pFirstSection->m_lWriteTotalSize和pFirstSection->m_lReadTotalSize的大小多少？

korpus

回復(fù) 7# gaojl0728


    你好，首先謝謝您哈。
1. 你第一行貼的是LOG_INFO， 我想看看LOG_DEBUG。

1. #define LOG_ERROR        Log_SysInfo(LOG_LEVEL_ERROR,__FILE__,__LINE__),Log_Msg
   
2. #define LOG_WARN        Log_SysInfo(LOG_LEVEL_WARN,__FILE__,__LINE__),Log_Msg
   
3. #define LOG_INFO        Log_SysInfo(LOG_LEVEL_INFO,__FILE__,__LINE__),Log_Msg
   
4. #define LOG_DEBUG        Log_SysInfo(LOG_LEVEL_DEBUG,__FILE__,__LINE__),Log_Msg

復(fù)制代碼

2. ufs_vFreeNormalMemory傳遞的為什么是雙重指針，難道會把參數(shù)設(shè)置為NULL?
如果是寫NULL的話，你就不需要memcpy測試了， 直接看看是不是NULL就行了

是的，就是為了將其置為空，打印過，釋放后，確實也是NULL

3.函數(shù)如下

1. void *ufs_MallocMemory(const long lSize)
   
2. {
   
3.     void *pAddr = NULL;
   
4.     if(lSize <= 0)
   
5.     {
   
6.         LOG_ERROR("malloc memory size less than zero");
   
7.         return NULL;
   
8.     }
   
9. 
   
10.     pAddr = malloc(lSize);
    
11.     if(NULL == pAddr)
    
12.     {
    
13.         LOG_ERROR("malloc memory size error!, malloc size(%d)", lSize);
    
14.         return NULL;
    
15.     }
    
16. 
    
17.     memset(pAddr, 0, lSize);
    
18. 
    
19.     return pAddr;
    
20. }
    
21. 
    
22. void ufs_vFreeNormalMemory(void **pAddr)
    
23. {
    
24. //    LOG_WARN("TEST MEMORY FREE[%p]", *pAddr);
    
25. 
    
26.     if(NULL == *pAddr)
    
27.         return;
    
28.     else
    
29.         free(*pAddr);
    
30.     *pAddr = NULL;
    
31. }
    

復(fù)制代碼

是用的malloc與free，在網(wǎng)上也查了說有可能被glibc回收，但是每次我運行一次的時候，內(nèi)存就增加了。

4. pFirstSection->m_lWriteTotalSize和pFirstSection->m_lReadTotalSize的大小多少？
這幾個值是設(shè)定的值，一般在10M以上

再次謝謝哈

folklore

內(nèi)存的問題我不猜～～



>>但是每次我運行一次的時候，內(nèi)存就增加了。

如果是指進(jìn)程已經(jīng)結(jié)束重跑的話。
就不用擔(dān)心內(nèi)存問題了。
進(jìn)程一結(jié)束，
滲漏的內(nèi)存也會被OS自動回收。

gaojl0728

回復(fù) 8# korpus

glibc只是一個可疑的點，但是不確定是不是真的被內(nèi)存池回收而沒換給內(nèi)核了。
看你的代碼沒什么問題， 沒有內(nèi)存泄露， 也沒看到死鎖
如果不是被內(nèi)存池緩存的話，我感覺可能只是一個top的顯示問題