pthread進程全域資源造成pthread_exit()操作無效？

thkaw

各位先進好

今天我寫了一隻socket的程式，
從主線程創建一個socket初始化的副線程thread_sockClientInit
該副線程也為分離型態的thread

裡面做一些與socket server連線握手等功能

當確認握手完後又在thread_sockClientInit()裏頭做了一個分離的thread_sockKeepAlive線程
然後就自己透過pthread_exit()回收掉自己

但在top跟ps裏頭，會發現thread_sockClientInit並無如期的回收掉
猜想是否因為裡頭掛了一些全域的socket變數，所以才造成pthread_exit()以及先前嘗試的pthread_cancel(pthread_self());
都無法正常的把該thread給移除呢？




以下是程式碼片段:

1. 
   
2. int client_sockfd;
   
3. int len;
   
4. struct sockaddr_in remote_addr; // SERVER STRUCT
   
5. char buff[BUFFER_SIZE];  // SOCK BUFFER
   
6. void clean(void* p)
   
7. {
   
8.         printf("clean()\n");
   
9. }
   
10. int thread_sockClientInit()
    
11. {
    
12.         memset(&remote_addr,0,sizeof(remote_addr)); // 數據初始化
    
13.         remote_addr.sin_family=AF_INET; // 設置為IP通訊
    
14.         remote_addr.sin_addr.s_addr=inet_addr(ServerIP);//ServerIP
    
15.         remote_addr.sin_port=htons(ServerPort); // ServerPort
    
16.         // 建立連接端socket--IPv4，TCP
    
17.         if((client_sockfd=socket(PF_INET,SOCK_STREAM,0))<0)
    
18.         {
    
19.                 perror("client socket creation failed");
    
20.                 exit(EXIT_FAILURE);
    
21.         }
    
22.         // SOCKET資訊開啟
    
23.         if(connect(client_sockfd,(struct sockaddr *)&remote_addr,sizeof(struct sockaddr))<0)
    
24.         {
    
25.                 perror("[Cloud]->>CServer connect failed");
    
26.         }
    
27.         else{
    
28.                 char initalCmd[]="xxxxxxxxxinit string~~~";
    
29. 
    
30.                 send(client_sockfd,initalCmd,strlen(initalCmd),0);
    
31.                 // 接收SERVER訊息
    
32.                 len=recv(client_sockfd,buff,BUFFER_SIZE,0);
    
33.                 printf("[Cloud]->>>Receive from server:%s\n",buff);
    
34.                 if(len<0)
    
35.                 {
    
36.                         perror("[Cloud]->>>Receive from server failed.<<<");
    
37.                         exit(EXIT_FAILURE);
    
38.                 }
    
39.                 else{
    
40.                         printf("[Cloud]->>>Sock init complete.<<<\n");
    
41. 
    
42.                         sockNTP();
    
43.                         sleep(1);
    
44.                         printf("[Cloud]->>>Start sockKeepAlive Process.<<<\n");
    
45. 
    
46.                         //KEEPALIVE為detached型態。
    
47.                         pthread_attr_t attr;
    
48.                         pthread_attr_init (&attr);
    
49.                         pthread_attr_setdetachstate(&attr, PTHREAD_CREATE_DETACHED);
    
50. 
    
51.                         pthread_t pid_sockKeepAlive;
    
52.                         int pret = pthread_create(&pid_sockKeepAlive,&attr, (void *) thread_sockKeepAlive, NULL);
    
53.                         if(pret!=0)
    
54.                         {
    
55.                                 printf ("Create pthread thread_sockInit error!\n");
    
56.                                 exit (1);
    
57.                         }
    
58.                         pthread_attr_destroy (&attr);
    
59.                 }
    
60.         }
    
61.         //close(client_sockfd);// 關閉SOCKET
    
62.         printf ("2EXIT pthread thread_sockInit!\n");
    
63.         pthread_exit(NULL);
    
64. }
    
65. 
    
66. int main(){
    
67.         pthread_attr_t tattr;
    
68.         pthread_attr_init (&tattr);
    
69.         pthread_attr_setdetachstate(&tattr, PTHREAD_CREATE_DETACHED);
    
70.         pthread_t pid_sockInit;
    
71.         pret = pthread_create(&pid_sockInit,&tattr, (void *) thread_sockClientInit, NULL);
    
72.         if(pret!=0)
    
73.         {
    
74.                 printf ("[Main]->>>Create pthread thread_sockClientInit error!<<<\n");
    
75.                 exit (1);
    
76.         }
    
77.         pthread_attr_destroy (&tattr);
    
78.         sleep(10);
    
79.         return(0);
    
80. }
    
81. 
    

复制代码

myworkstation

回复 1# thkaw


    确认已经执行pthread_exit()了？你在main函数中写法有很大问题，如果main函数返回将导致进程退出，这将使得进程内所有线程被终止。无论创建的线程是否detach都不应无视既存线程的状态通过简单的sleep后退出。如果你使用pthread_cancel的话需要使用pthread_cleanup_push注册资源清理函数，否则资源不能正常释放。

djsxut

可能是thread_sockClientInit这个函数执行的太快， 在pthread_create函数返回之前就停止了运行，停止运行后就很有可能将线程号和系统资源移交给thread_sockKeepAlive线程使用。试试在 int pret = pthread_create(&pid_sockKeepAlive,&attr, (void *) thread_sockKeepAlive, NULL); 后多睡眠下。

thkaw

謝謝兩位先進

我發現是小弟我愚鈍...搞了個烏龍！

其實進程還是有被回收掉
只是因為thread_sockClientInit裏頭創建thread_sockKeepAlive的速度太快
加上創建完該thread後緊接著把自己結束掉，
所以在top底下看起來thread數量並沒有增減的情況!

我剛剛在int pret = pthread_create(&pid_sockKeepAlive,&attr, (void *) thread_sockKeepAlive, NULL);
後面sleep(2)秒

在觀察了top之後
才恍然大悟...

所以我的clean也是正常的,exit也是沒問題的


完全是自己大意疏忽掉了

djsxut

用繁体字， 是台湾或者香港的吗？ {:3_189:}

thkaw

回复 5# djsxut


   
哈哈，我是台灣的

剛學習Linux編程還不到兩個月~
未來涵請多多指教！

djsxut

呵呵， 互相学习。{:3_189:} 回复 6# thkaw