fltrBuffer加同步锁，避免错误清除新添加的消息。

2019-01-25 09:55:09 +08:00
parent e1eb9a4eaa
commit ecbaee67ae
1 changed files with 6 additions and 2 deletions
@@ -33,8 +33,12 @@ public class FltrSendBufferService implements IFltrSendBufferService {
 		}
 		
 		//
-		FLTR[] fltrs = (FLTR[]) fltrBuffer.toArray(new FLTR[fltrBuffer.size()]); // TODO 转换出错
-		fltrBuffer.clear();//to fix ,获取及清空过程中是否要加锁
+		FLTR[] fltrs = null;
+		synchronized (fltrBuffer) {
+			fltrs = (FLTR[]) fltrBuffer.toArray(new FLTR[fltrBuffer.size()]); 
+			fltrBuffer.clear();
+		}
+		
 		
 		return Arrays.asList(fltrs);
 	}