多線程死鎖了，給下gdb日志，幫我分析下

jd808

1. (gdb) info threads
   
2.   Id   Target Id         Frame
   
3.   7    Thread 0x7f82e25eb700 (LWP 24196) "Xgateway" __lll_lock_wait () at ../nptl/sysdeps/unix/sysv/linux/x86_64/lowlevellock.S:135
   
4.   6    Thread 0x7f82e1dea700 (LWP 24197) "Xgateway" __lll_lock_wait () at ../nptl/sysdeps/unix/sysv/linux/x86_64/lowlevellock.S:135
   
5.   5    Thread 0x7f82e15e9700 (LWP 24198) "Xgateway" __lll_lock_wait () at ../nptl/sysdeps/unix/sysv/linux/x86_64/lowlevellock.S:135
   
6.   4    Thread 0x7f82e0de8700 (LWP 24199) "Xgateway" __lll_lock_wait () at ../nptl/sysdeps/unix/sysv/linux/x86_64/lowlevellock.S:135
   
7.   3    Thread 0x7f82e05e7700 (LWP 24200) "Xgateway" __lll_lock_wait () at ../nptl/sysdeps/unix/sysv/linux/x86_64/lowlevellock.S:135
   
8.   2    Thread 0x7f82dfde6700 (LWP 24201) "Xgateway" 0x00007f82e26a948d in nanosleep () at ../sysdeps/unix/syscall-template.S:81
   
9. * 1    Thread 0x7f82e3ea7740 (LWP 24195) "Xgateway" __lll_lock_wait () at ../nptl/sysdeps/unix/sysv/linux/x86_64/lowlevellock.S:135
   
10. (gdb) thread 1
    
11. [Switching to thread 1 (Thread 0x7f82e3ea7740 (LWP 24195))]
    
12. #0  __lll_lock_wait () at ../nptl/sysdeps/unix/sysv/linux/x86_64/lowlevellock.S:135
    
13. 135        2:        movl        %edx, %eax
    
14. (gdb) bt
    
15. #0  __lll_lock_wait () at ../nptl/sysdeps/unix/sysv/linux/x86_64/lowlevellock.S:135
    
16. #1  0x00007f82e3a83d32 in _L_lock_791 () from /lib64/libpthread.so.0
    
17. #2  0x00007f82e3a83c38 in __GI___pthread_mutex_lock (mutex=0x1cb04f8) at pthread_mutex_lock.c:64
    
18. #3  0x0000000000415709 in TServer::CloseEvent (this=<optimized out>, conn=0x1cb0370, events=<optimized out>)
    
19.     at gateway/src/TServer.cpp:340
    
20. #4  0x00007f82e36001ee in bufferevent_readcb (fd=20, event=<optimized out>, arg=0x1ca4500) at bufferevent_sock.c:196
    
21. #5  0x00007f82e3605849 in event_persist_closure (ev=<optimized out>, base=0x1ca15c0) at event.c:1531
    
22. #6  event_process_active_single_queue (base=base@entry=0x1ca15c0, activeq=0x1badc90, max_to_process=max_to_process@entry=2147483647,
    
23.     endtime=endtime@entry=0x0) at event.c:1590
    
24. #7  0x00007f82e36060ff in event_process_active (base=0x1ca15c0) at event.c:1689
    
25. #8  event_base_loop (base=0x1ca15c0, flags=0) at event.c:1912
    
26. #9  0x0000000000414e01 in MultiServer::StartRun (this=0x1c53880) at gateway/src/MultiServer.cpp:329
    
27. #10 0x000000000041ce52 in TControl::Run (this=this@entry=0x7fff7eaf4ab0) at gateway/src/TControl.cpp:30
    
28. #11 0x00000000004060e0 in main (argc=1, argv=0x7fff7eaf4bc8) at gateway/src/node_gateway.cpp:64
    
29. (gdb) thread 3
    
30. [Switching to thread 3 (Thread 0x7f82e05e7700 (LWP 24200))]
    
31. #0  __lll_lock_wait () at ../nptl/sysdeps/unix/sysv/linux/x86_64/lowlevellock.S:135
    
32. 135        2:        movl        %edx, %eax
    
33. (gdb) bt
    
34. #0  __lll_lock_wait () at ../nptl/sysdeps/unix/sysv/linux/x86_64/lowlevellock.S:135
    
35. #1  0x00007f82e3a83d32 in _L_lock_791 () from /lib64/libpthread.so.0
    
36. #2  0x00007f82e3a83c38 in __GI___pthread_mutex_lock (mutex=0x1cb04f8) at pthread_mutex_lock.c:64
    
37. #3  0x0000000000406869 in TEngine::Base_Client_Lock (this=0x1cad670, send_conn=0x1cb0370, command=0x7f82e05e6bf0 "\031\260!",
    
38.     size=52, is_zip=1) at gateway/src/TEngine.cpp:113
    
39. #4  0x000000000040766c in TUserEngine::send_map_xy_client (this=<optimized out>, pcon=<optimized out>, Build_conn=<optimized out>,
    
40.     command=<optimized out>, cmdlen=<optimized out>, send_count=<optimized out>) at gateway/src/TUserEngine.cpp:794
    
41. #5  0x00000000004131ec in operator() (__args#4=0x7f82e05e6bac, __args#3=52, __args#2=0x7f82e05e6bf0 "\031\260!", __args#1=0x1cb0370,
    
42.     __args#0=<optimized out>, this=0x7f82e05e6bd0) at /usr/include/c++/4.8.2/tr1/functional:2146
    
43. #6  BaseTEngine::CallConnList(std::tr1::function<int (Conn*, Conn*, char const*, int, void*)>, Conn*, char const*, int, void*) (
    
44.     this=this@entry=0x1cad670, f=..., ActConn=ActConn@entry=0x1cb0370, command=command@entry=0x7f82e05e6bf0 "\031\260!",
    
45.     cmdlen=cmdlen@entry=52, n=n@entry=0x7f82e05e6bac) at gateway/src/BaseTEngine.cpp:166
    
46. #7  0x0000000000409380 in TUserEngine::_MoveXY (this=this@entry=0x1cad670, x=x@entry=211, y=y@entry=2414, pint AddToWriteBuffer(const void *buffer, int len)
    
47.     {
    
48. //                m_WriteBuf = bufferevent_get_output(m_bev);
    
49.                 //printf("m_WriteBuf[%p]\n", m_WriteBuf);
    
50.             if(fd_type>0 && m_WriteBuf!=NULL) {
    
51.                         int res = evbuffer_add(m_WriteBuf, buffer, len);
    
52. //                        int res = bufferevent_write(m_bev, buffer, len);//這個和上面evbuffer_add是一樣的
    
53.                         return res;
    
54. 
    
55.                 }
    
56.                 else
    
57.                         return -1;
    
58.     }arameter=1,
    
59.     hero_user_id=-1) at gateway/src/TUserEngine.cpp:643
    
60. #8  0x00000000004093f7 in TUserEngine::moveXY (this=this@entry=0x1cad670,
    
61.     command=command@entry=0x7f82c8006104 <incomplete sequence \323>, DataLen=DataLen@entry=16) at gateway/src/TUserEngine.cpp:592
    
62. #9  0x000000000040aa76 in TUserEngine::ExecCmd (this=this@entry=0x1cad670, command=0x7f82c8006104 <incomplete sequence \323>,
    
63.     DataLen=DataLen@entry=16) at gateway/src/TUserEngine.cpp:174
    
64. #10 0x000000000040af82 in TUserEngine::Process (this=0x1cad670, arg=<optimized out>, pconn=<optimized out>, CMD=<optimized out>,
    
65.     CMDlen=<optimized out>) at gateway/src/TUserEngine.cpp:42
    
66. #11 0x0000000000415fe6 in TServer::ThreadProcessD (this=<optimized out>, pcon=0x1cb0370, CMD=<optimized out>, CMDlen=43,
    
67.     arg=0x1ca1c90) at gateway/src/TServer.cpp:123
    
68. #12 0x0000000000416279 in TServer::ThreadProcess (this=<optimized out>, arg=<optimized out>) at gateway/src/TServer.cpp:186
    
69. #13 0x0000000000414520 in MultiServer::WorkerLibevent (arg=<optimized out>) at gateway/src/MultiServer.cpp:361
    
70. #14 0x00007f82e3a81df5 in start_thread (arg=0x7f82e05e7700) at pthread_create.c:308
    
71. #15 0x00007f82e26e21ad in clone () at ../sysdeps/unix/sysv/linux/x86_64/clone.S:113
    
72. (gdb) thread 4
    
73. [Switching to thread 4 (Thread 0x7f82e0de8700 (LWP 24199))]
    
74. #0  __lll_lock_wait () at ../nptl/sysdeps/unix/sysv/linux/x86_64/lowlevellock.S:135
    
75. 135        2:        movl        %edx, %eax
    
76. (gdb) bt
    
77. #0  __lll_lock_wait () at ../nptl/sysdeps/unix/sysv/linux/x86_64/lowlevellock.S:135
    
78. #1  0x00007f82e3a83d32 in _L_lock_791 () from /lib64/libpthread.so.0
    
79. #2  0x00007f82e3a83c38 in __GI___pthread_mutex_lock (mutex=0x1cb04f8) at pthread_mutex_lock.c:64
    
80. #3  0x0000000000406869 in TEngine::Base_Client_Lock (this=0x1caa750, send_conn=0x1cb0370, command=0x7f82e0de7bf0 "\031\260!",
    
81.     size=52, is_zip=1) at gateway/src/TEngine.cpp:113
    
82. #4  0x000000000040766c in TUserEngine::send_map_xy_client (this=<optimized out>, pcon=<optimized out>, Build_conn=<optimized out>,
    
83.     command=<optimized out>, cmdlen=<optimized out>, send_count=<optimized out>) at gateway/src/TUserEngine.cpp:794
    
84. #5  0x00000000004131ec in operator() (__args#4=0x7f82e0de7bac, __args#3=52, __args#2=0x7f82e0de7bf0 "\031\260!", __args#1=0x1cb0370,
    
85.     __args#0=<optimized out>, this=0x7f82e0de7bd0) at /usr/include/c++/4.8.2/tr1/functional:2146
    
86. #6  BaseTEngine::CallConnList(std::tr1::function<int (Conn*, Conn*, char const*, int, void*)>, Conn*, char const*, int, void*) (
    
87.     this=this@entry=0x1caa750, f=..., ActConn=ActConn@entry=0x1cb0370, command=command@entry=0x7f82e0de7bf0 "\031\260!",
    
88.     cmdlen=cmdlen@entry=52, n=n@entry=0x7f82e0de7bac) at gateway/src/BaseTEngine.cpp:166
    
89. #7  0x0000000000409380 in TUserEngine::_MoveXY (this=this@entry=0x1caa750, x=x@entry=336, y=y@entry=2251, parameter=1,
    
90.     hero_user_id=-1) at gateway/src/TUserEngine.cpp:643
    
91. #8  0x00000000004093f7 in TUserEngine::moveXY (this=this@entry=0x1caa750, command=command@entry=0x7f82c0007384 "P\001",
    
92.     DataLen=DataLen@entry=16) at gateway/src/TUserEngine.cpp:592
    
93. #9  0x000000000040aa76 in TUserEngine::ExecCmd (this=this@entry=0x1caa750, command=0x7f82c0007384 "P\001", DataLen=DataLen@entry=16)
    
94.     at gateway/src/TUserEngine.cpp:174
    
95. #10 0x000000000040af82 in TUserEngine::Process (this=0x1caa750, arg=<optimized out>, pconn=<optimized out>, CMD=<optimized out>,
    
96.     CMDlen=<optimized out>) at gateway/src/TUserEngine.cpp:42
    
97. #11 0x0000000000415fe6 in TServer::ThreadProcessD (this=<optimized out>, pcon=0x1cb0370, CMD=<optimized out>, CMDlen=43,
    
98.     arg=0x1ca1c40) at gateway/src/TServer.cpp:123
    
99. #12 0x0000000000416279 in TServer::ThreadProcess (this=<optimized out>, arg=<optimized out>) at gateway/src/TServer.cpp:186
    
100. #13 0x0000000000414520 in MultiServer::WorkerLibevent (arg=<optimized out>) at gateway/src/MultiServer.cpp:361
     
101. #14 0x00007f82e3a81df5 in start_thread (arg=0x7f82e0de8700) at pthread_create.c:308
     
102. #15 0x00007f82e26e21ad in clone () at ../sysdeps/unix/sysv/linux/x86_64/clone.S:113
     
103. (gdb) thread 5
     
104. [Switching to thread 5 (Thread 0x7f82e15e9700 (LWP 24198))]
     
105. #0  __lll_lock_wait () at ../nptl/sysdeps/unix/sysv/linux/x86_64/lowlevellock.S:135
     
106. 135        2:        movl        %edx, %eax
     
107. (gdb) bt
     
108. #0  __lll_lock_wait () at ../nptl/sysdeps/unix/sysv/linux/x86_64/lowlevellock.S:135
     
109. #1  0x00007f82e3a83d4d in _L_lock_840 () from /lib64/libpthread.so.0
     
110. #2  0x00007f82e3a83c6a in __GI___pthread_mutex_lock (mutex=0x1ca4820) at pthread_mutex_lock.c:85
     
111. #3  0x00007f82e3609852 in debug_lock_lock (mode=<optimized out>, lock_=0x1cb0750) at evthread.c:227
     
112. #4  0x00007f82e35f85ac in evbuffer_add (buf=0x1ca4790, data_in=0x1cb1ac0, datlen=79) at buffer.c:1725
     
113. #5  0x00000000004182d7 in AddToWriteBuffer (this=0x1cb0370, this=0x1cb0370, len=<optimized out>, buffer=<optimized out>)
     
114.     at gateway/src/../inc/MultiServer.h:232
     
115. #6  socket_send (conn=conn@entry=0x1cb0370, buffer=<optimized out>, size=<optimized out>) at gateway/src/function.cpp:91
     
116. #7  0x00000000004068b3 in TEngine::Base_Client_Lock (this=0x1ca7830, send_conn=0x1cb0370, command=0x7f82e15e8bf0 "\031\260!",
     
117.     size=<optimized out>, is_zip=1) at gateway/src/TEngine.cpp:128
     
118. #8  0x000000000040766c in TUserEngine::send_map_xy_client (this=<optimized out>, pcon=<optimized out>, Build_conn=<optimized out>,
     
119.     command=<optimized out>, cmdlen=<optimized out>, send_count=<optimized out>) at gateway/src/TUserEngine.cpp:794
     
120. #9  0x00000000004131ec in operator() (__args#4=0x7f82e15e8bac, __args#3=52, __args#2=0x7f82e15e8bf0 "\031\260!", __args#1=0x1cb0370,
     
121.     __args#0=<optimized out>, this=0x7f82e15e8bd0) at /usr/include/c++/4.8.2/tr1/functional:2146
     
122. #10 BaseTEngine::CallConnList(std::tr1::function<int (Conn*, Conn*, char const*, int, void*)>, Conn*, char const*, int, void*) (
     
123.     this=this@entry=0x1ca7830, f=..., ActConn=ActConn@entry=0x1cb0370, command=command@entry=0x7f82e15e8bf0 "\031\260!",
     
124.     cmdlen=cmdlen@entry=52, n=n@entry=0x7f82e15e8bac) at gateway/src/BaseTEngine.cpp:166
     
125. #11 0x0000000000409380 in TUserEngine::_MoveXY (this=this@entry=0x1ca7830, x=x@entry=266, y=y@entry=2315, parameter=1,
     
126.     hero_user_id=-1) at gateway/src/TUserEngine.cpp:643
     
127. #12 0x00000000004093f7 in TUserEngine::moveXY (this=this@entry=0x1ca7830, command=command@entry=0x7f82d8003594 "\n\001",
     
128.     DataLen=DataLen@entry=16) at gateway/src/TUserEngine.cpp:592
     
129. #13 0x000000000040aa76 in TUserEngine::ExecCmd (this=this@entry=0x1ca7830, command=0x7f82d8003594 "\n\001", DataLen=DataLen@entry=16)
     
130.     at gateway/src/TUserEngine.cpp:174
     
131. #14 0x000000000040af82 in TUserEngine::Process (this=0x1ca7830, arg=<optimized out>, pconn=<optimized out>, CMD=<optimized out>,
     
132.     CMDlen=<optimized out>) at gateway/src/TUserEngine.cpp:42
     
133. #15 0x0000000000415fe6 in TServer::ThreadProcessD (this=<optimized out>, pcon=0x1cb0370, CMD=<optimized out>, CMDlen=43,
     
134.     arg=0x1ca1bf0) at gateway/src/TServer.cpp:123
     
135. #16 0x0000000000416279 in TServer::ThreadProcess (this=<optimized out>, arg=<optimized out>) at gateway/src/TServer.cpp:186
     
136. #17 0x0000000000414520 in MultiServer::WorkerLibevent (arg=<optimized out>) at gateway/src/MultiServer.cpp:361
     
137. #18 0x00007f82e3a81df5 in start_thread (arg=0x7f82e15e9700) at pthread_create.c:308
     
138. ---Type <return> to continue, or q <return> to quit---
     
139. #19 0x00007f82e26e21ad in clone () at ../sysdeps/unix/sysv/linux/x86_64/clone.S:113
     
140. (gdb) thread 6
     
141. [Switching to thread 6 (Thread 0x7f82e1dea700 (LWP 24197))]
     
142. #0  __lll_lock_wait () at ../nptl/sysdeps/unix/sysv/linux/x86_64/lowlevellock.S:135
     
143. 135        2:        movl        %edx, %eax
     
144. (gdb) bt
     
145. #0  __lll_lock_wait () at ../nptl/sysdeps/unix/sysv/linux/x86_64/lowlevellock.S:135
     
146. #1  0x00007f82e3a83d32 in _L_lock_791 () from /lib64/libpthread.so.0
     
147. #2  0x00007f82e3a83c38 in __GI___pthread_mutex_lock (mutex=0x1cb04f8) at pthread_mutex_lock.c:64
     
148. #3  0x0000000000406869 in TEngine::Base_Client_Lock (this=0x1ca4910, send_conn=0x1cb0370, command=0x7f82e1de9bf0 "\031\260!",
     
149.     size=52, is_zip=1) at gateway/src/TEngine.cpp:113
     
150. #4  0x000000000040766c in TUserEngine::send_map_xy_client (this=<optimized out>, pcon=<optimized out>, Build_conn=<optimized out>,
     
151.     command=<optimized out>, cmdlen=<optimized out>, send_count=<optimized out>) at gateway/src/TUserEngine.cpp:794
     
152. #5  0x00000000004131ec in operator() (__args#4=0x7f82e1de9bac, __args#3=52, __args#2=0x7f82e1de9bf0 "\031\260!", __args#1=0x1cb0370,
     
153.     __args#0=<optimized out>, this=0x7f82e1de9bd0) at /usr/include/c++/4.8.2/tr1/functional:2146
     
154. #6  BaseTEngine::CallConnList(std::tr1::function<int (Conn*, Conn*, char const*, int, void*)>, Conn*, char const*, int, void*) (
     
155.     this=this@entry=0x1ca4910, f=..., ActConn=ActConn@entry=0x1cb0370, command=command@entry=0x7f82e1de9bf0 "\031\260!",
     
156.     cmdlen=cmdlen@entry=52, n=n@entry=0x7f82e1de9bac) at gateway/src/BaseTEngine.cpp:166
     
157. #7  0x0000000000409380 in TUserEngine::_MoveXY (this=this@entry=0x1ca4910, x=x@entry=405, y=y@entry=2373, parameter=1,
     
158.     hero_user_id=-1) at gateway/src/TUserEngine.cpp:643
     
159. #8  0x00000000004093f7 in TUserEngine::moveXY (this=this@entry=0x1ca4910, command=command@entry=0x7f82d0005de4 "\225\001",
     
160.     DataLen=DataLen@entry=16) at gateway/src/TUserEngine.cpp:592
     
161. #9  0x000000000040aa76 in TUserEngine::ExecCmd (this=this@entry=0x1ca4910, command=0x7f82d0005de4 "\225\001",
     
162.     DataLen=DataLen@entry=16) at gateway/src/TUserEngine.cpp:174
     
163. #10 0x000000000040af82 in TUserEngine::Process (this=0x1ca4910, arg=<optimized out>, pconn=<optimized out>, CMD=<optimized out>,
     
164.     CMDlen=<optimized out>) at gateway/src/TUserEngine.cpp:42
     
165. #11 0x0000000000415fe6 in TServer::ThreadProcessD (this=<optimized out>, pcon=0x1cb0370, CMD=<optimized out>, CMDlen=43,
     
166.     arg=0x1ca1ba0) at gateway/src/TServer.cpp:123
     
167. #12 0x0000000000416279 in TServer::ThreadProcess (this=<optimized out>, arg=<optimized out>) at gateway/src/TServer.cpp:186
     
168. #13 0x0000000000414520 in MultiServer::WorkerLibevent (arg=<optimized out>) at gateway/src/MultiServer.cpp:361
     
169. #14 0x00007f82e3a81df5 in start_thread (arg=0x7f82e1dea700) at pthread_create.c:308
     
170. #15 0x00007f82e26e21ad in clone () at ../sysdeps/unix/sysv/linux/x86_64/clone.S:113
     
171. (gdb) thread 7
     
172. [Switching to thread 7 (Thread 0x7f82e25eb700 (LWP 24196))]
     
173. #0  __lll_lock_wait () at ../nptl/sysdeps/unix/sysv/linux/x86_64/lowlevellock.S:135
     
174. 135        2:        movl        %edx, %eax
     
175. (gdb) bt
     
176. #0  __lll_lock_wait () at ../nptl/sysdeps/unix/sysv/linux/x86_64/lowlevellock.S:135
     
177. #1  0x00007f82e3a83d32 in _L_lock_791 () from /lib64/libpthread.so.0
     
178. #2  0x00007f82e3a83c38 in __GI___pthread_mutex_lock (mutex=0x1cb04f8) at pthread_mutex_lock.c:64
     
179. #3  0x00000000004158a1 in TServer::AutoCloseEvent (this=<optimized out>, conn=0x1cb0370) at gateway/src/TServer.cpp:525
     
180. #4  0x0000000000416693 in TServer::TimeOutCb (this=this@entry=0x1c53880) at gateway/src/TServer.cpp:500
     
181. #5  0x00000000004167a2 in TServer::TimerCb (this=0x1c53880, arg=0x1cae4f0) at gateway/src/TServer.cpp:443
     
182. #6  0x00000000004144e1 in MultiServer::WorkerTimerEvent (arg=<optimized out>) at gateway/src/MultiServer.cpp:342
     
183. #7  0x00007f82e3a81df5 in start_thread (arg=0x7f82e25eb700) at pthread_create.c:308
     
184. #8  0x00007f82e26e21ad in clone () at ../sysdeps/unix/sysv/linux/x86_64/clone.S:113
     

復(fù)制代碼

代碼大致是

1. 
   
2. int TEngine::Base_Client_Lock(Conn *send_conn,const char* command,int size, int is_zip)
   
3. {
   
4.         if(send_conn==NULL)return -1;
   
5.         pthread_mutex_lock(&send_conn->UserCMDLock);
   
6.         if(send_conn==NULL)
   
7.                 return -1;
   
8. 
   
9.         if(send_conn->is_down==1){
   
10.                 pthread_mutex_unlock(&send_conn->UserCMDLock);
    
11.                 return -1;
    
12.         }
    
13. 
    
14.         int mid=proto->MODLUE_ID<0?proto->MODLUE_ID:9999999;
    
15.         if (Client_BuildPact(mid,m_sbuff, command,size, is_zip) == -1)
    
16.         {
    
17.                 pthread_mutex_unlock(&send_conn->UserCMDLock);
    
18.                 return -1;
    
19.         }
    
20.         socket_send(send_conn, m_sbuff->buff,m_sbuff->data_size);
    
21.         pthread_mutex_unlock(&send_conn->UserCMDLock);
    
22.         return 0;
    
23. }
    
24. 
    
25. int socket_send(Conn *conn,const  char *buffer, int size)
    
26. {
    
27. //        pthread_t pid = pthread_self();
    
28. //        printf("%p|%ld,添加到發(fā)送緩沖區(qū)1\n", conn, pid);
    
29.         //pthread_mutex_lock(&conn->GetThread()->send_mutex);   //ok
    
30.         //pthread_mutex_lock(&conn->send_mutex);
    
31.         //printf("%p|%ld,添加到發(fā)送緩沖區(qū)2\n", conn, pid);
    
32.         if (conn != NULL)
    
33.                 conn->AddToWriteBuffer((void *)buffer, size);
    
34. 
    
35. //        printf("%p|%ld,添加成功并返回1\n", conn, pid);
    
36.         //pthread_mutex_unlock(&conn->send_mutex);
    
37.         //pthread_mutex_unlock(&conn->GetThread()->send_mutex);
    
38.         //printf("%p|%ld,添加成功并返回2\n", conn, pid);
    
39.        
    
40.         return 0;
    
41. }
    
42. 
    
43. int AddToWriteBuffer(const void *buffer, int len)
    
44.     {
    
45. //                m_WriteBuf = bufferevent_get_output(m_bev);
    
46.                 //printf("m_WriteBuf[%p]\n", m_WriteBuf);
    
47.             if(fd_type>0 && m_WriteBuf!=NULL) {
    
48.                         int res = evbuffer_add(m_WriteBuf, buffer, len);
    
49. //                        int res = bufferevent_write(m_bev, buffer, len);//這個和上面evbuffer_add是一樣的
    
50.                         return res;
    
51. 
    
52.                 }
    
53.                 else
    
54.                         return -1;
    
55.     }
    
56. 
    

復(fù)制代碼

用的是libevent框架，evbuffer_add里面libevent本身有個鎖，他鎖住不放，會導(dǎo)致上一層的pthread_mutex_unlock(&send_conn->UserCMDLock);不會釋放，導(dǎo)致其他線程卡在pthread_mutex_lock(&send_conn->UserCMDLock);鎖這里，但問題是，從日志中無法確定evbuffer_add里面的鎖為什么不釋放，因?yàn)樗�不會�?dǎo)致交叉鎖呀，鎖都在這個函數(shù)里封裝好的，而外面想調(diào)用evbuffer_add，必須經(jīng)過pthread_mutex_lock(&send_conn->UserCMDLock);鎖，怎么破？？？？？

happy_fish100

有個地方在函數(shù)返回前沒有unlock。

貼出一下：
        pthread_mutex_lock(&send_conn->UserCMDLock);
        if(send_conn==NULL)
                return -1;

jd808

happy_fish100 發(fā)表于 2016-01-10 09:14
有個地方在函數(shù)返回前沒有unlock。

貼出一下：

這個沒錯的，send_conn==NULL的時候是無法解鎖的，而且這把鎖也已經(jīng)消失了。

lxyscls

回復(fù) 3# jd808

1. pthread_mutex_lock(&send_conn->UserCMDLock);
   
2. if(send_conn==NULL)
   
3.     return -1;

復(fù)制代碼

你這樣實(shí)現(xiàn)，本身就是錯誤的，send_conn == NULL，lock就crash了。你需要的是判斷l(xiāng)ock的返回狀態(tài)。

jd808

lxyscls 發(fā)表于 2016-01-11 10:51
回復(fù) 3# jd808 你這樣實(shí)現(xiàn)，本身就是錯誤的，send_conn == NULL，lock就crash了。你需要的是判斷l(xiāng)ock的返回 ...

沒聽過可以判斷互斥鎖的狀態(tài)呀

jd808

lxyscls 發(fā)表于 2016-01-11 10:51
回復(fù) 3# jd808 你這樣實(shí)現(xiàn)，本身就是錯誤的，send_conn == NULL，lock就crash了。你需要的是判斷l(xiāng)ock的返回 ...

而且這也沒錯，a線程鎖住他，準(zhǔn)備將句柄刪除，b線程在鎖這里等待，a線程刪除完成后鎖不存在，pconn置為NULL，如果b線程沒報(bào)錯，順利鎖住，這個時候pcon可能等于NULL，所以這個時候需要判斷pcon是否等于NULL，如果等于NULL，說明句柄實(shí)體都沒了，就沒有繼續(xù)下去的必要，鎖也將不存在了，（鎖是建立在pcon里面的。）

lxyscls

回復(fù) 5# jd808


    那你需要man pthread_mutex_lock

lxyscls

回復(fù) 6# jd808


    destroy掉了，你還能lock得住，才真是見鬼了
    要是沒有destroy，你只是free了外部的那個結(jié)構(gòu)體，豈不是就資源泄露了？

happy_fish100

lock住之后判斷宿主指針是否為空，總感覺這樣的用法不科學(xué)�。╨ock之前已經(jīng)判斷過了）

如果其他線程會釋放宿主指針，可以使用如下步驟：
1. lock，實(shí)現(xiàn)互斥
2. 告訴使用宿主指針的其他線程宿主即將釋放，可以在宿主結(jié)構(gòu)體中增加一個成員變量
3. unlock
4. 延遲釋放指針，延遲時間根據(jù)實(shí)際情況設(shè)置。

當(dāng)然也可以有其他實(shí)現(xiàn)方式，比如智能指針（引用計(jì)數(shù)為0才真正釋放空間）。
建議使用智能指針方式。

jd808

lxyscls 發(fā)表于 2016-01-11 11:13
回復(fù) 6# jd808

他們同時在競爭鎖，結(jié)果刪除線程搶贏了，操作線程搶輸了，那么操作線程那個家伙肯定是在排隊(duì)，當(dāng)刪除線程操作完成后，那個家伙的內(nèi)存肯定也不存在了，但不知道他在另外一個線程哪里排隊(duì)情況如何？如果鎖計(jì)數(shù)器是歸0，還是不可預(yù)知，但可以肯定的時候，輪到他的時候，不關(guān)如何，都能夠鎖成功。