up

Author: kbengine

Event.cs

@@ -73,6 +73,22 @@ public static bool isPause()
 			return _isPauseOut;
 		}
 
+		public static void monitor_Enter(object obj)
+		{
+			if(KBEngineApp.app == null || KBEngineApp.app.getInitArgs().isMultiThreads == false)
+				return;
+			
+			Monitor.Enter(obj);
+		}
+
+		public static void monitor_Exit(object obj)
+		{
+			if(KBEngineApp.app == null || KBEngineApp.app.getInitArgs().isMultiThreads == false)
+				return;
+			
+			Monitor.Exit(obj);
+		}
+		
 		public static bool hasRegisterOut(string eventname)
 		{
 			return _hasRegister(events_out, eventname);
@@ -87,9 +103,9 @@ private static bool _hasRegister(Dictionary<string, List<Pair>> events, string e
 		{
 			bool has = false;
 
-			Monitor.Enter(events);
+			monitor_Enter(events);
 			has = events.ContainsKey(eventname);
-			Monitor.Exit(events);
+			monitor_Exit(events);
 
 			return has;
 		}
@@ -128,20 +144,20 @@ private static bool register(Dictionary<string, List<Pair>> events, string event
 				return false;
 			}
 
-			Monitor.Enter(events);
+			monitor_Enter(events);
 			if(!events.TryGetValue(eventname, out lst))
 			{
 				lst = new List<Pair>();
 				lst.Add(pair);
 				//Dbg.DEBUG_MSG("Event::register: event(" + eventname + ")!");
 				events.Add(eventname, lst);
-				Monitor.Exit(events);
+				monitor_Exit(events);
 				return true;
 			}
 
 			//Dbg.DEBUG_MSG("Event::register: event(" + eventname + ")!");
 			lst.Add(pair);
-			Monitor.Exit(events);
+			monitor_Exit(events);
 			return true;
 		}
 
@@ -157,12 +173,12 @@ public static bool deregisterIn(string eventname, object obj, string funcname)
 
 		private static bool deregister(Dictionary<string, List<Pair>> events, string eventname, object obj, string funcname)
 		{
-			Monitor.Enter(events);
+			monitor_Enter(events);
 			List<Pair> lst = null;
 
 			if(!events.TryGetValue(eventname, out lst))
 			{
-				Monitor.Exit(events);
+				monitor_Exit(events);
 				return false;
 			}
 
@@ -172,12 +188,12 @@ private static bool deregister(Dictionary<string, List<Pair>> events, string eve
 				{
 					//Dbg.DEBUG_MSG("Event::deregister: event(" + eventname + ":" + funcname + ")!");
 					lst.RemoveAt(i);
-					Monitor.Exit(events);
+					monitor_Exit(events);
 					return true;
 				}
 			}
 
-			Monitor.Exit(events);
+			monitor_Exit(events);
 			return false;
 		}
 
@@ -193,7 +209,7 @@ public static bool deregisterIn(object obj)
 
 		private static bool deregister(Dictionary<string, List<Pair>> events, object obj)
 		{
-			Monitor.Enter(events);
+			monitor_Enter(events);
 
 			foreach(KeyValuePair<string, List<Pair>> e in events)
 			{
@@ -210,7 +226,7 @@ private static bool deregister(Dictionary<string, List<Pair>> events, object obj
 				}
 			}
 
-			Monitor.Exit(events);
+			monitor_Exit(events);
 			return true;
 		}
 
@@ -244,7 +260,7 @@ public static void fireAll(string eventname, object[] args)
 
 		private static void fire_(Dictionary<string, List<Pair>> events, LinkedList<EventObj> firedEvents, string eventname, object[] args)
 		{
-			Monitor.Enter(events);
+			monitor_Enter(events);
 			List<Pair> lst = null;
 
 			if(!events.TryGetValue(eventname, out lst))
@@ -254,7 +270,7 @@ private static void fire_(Dictionary<string, List<Pair>> events, LinkedList<Even
 				else
 					Dbg.WARNING_MSG("Event::fireOut: event(" + eventname + ") not found!");
 
-				Monitor.Exit(events);
+				monitor_Exit(events);
 				return;
 			}
 
@@ -266,12 +282,12 @@ private static void fire_(Dictionary<string, List<Pair>> events, LinkedList<Even
 				firedEvents.AddLast(eobj);
 			}
 
-			Monitor.Exit(events);
+			monitor_Exit(events);
 		}
 
 		public static void processOutEvents()
 		{
-			Monitor.Enter(events_out);
+			monitor_Enter(events_out);
 
 			if(firedEvents_out.Count > 0)
 			{
@@ -283,7 +299,7 @@ public static void processOutEvents()
 				firedEvents_out.Clear();
 			}
 
-			Monitor.Exit(events_out);
+			monitor_Exit(events_out);
 
 			while (doingEvents_out.Count > 0 && !_isPauseOut) 
 			{
@@ -311,7 +327,7 @@ public static void processOutEvents()
 
 		public static void processInEvents()
 		{
-			Monitor.Enter(events_in);
+			monitor_Enter(events_in);
 
 			if(firedEvents_in.Count > 0)
 			{
@@ -323,7 +339,7 @@ public static void processInEvents()
 				firedEvents_in.Clear();
 			}
 
-			Monitor.Exit(events_in);
+			monitor_Exit(events_in);
 
 			while (doingEvents_in.Count > 0) 
 			{

KBEMain.cs

@@ -61,6 +61,8 @@ public virtual void initKBEngine()
 		args.SEND_BUFFER_MAX = (UInt32)SEND_BUFFER_MAX;
 		args.RECV_BUFFER_MAX = (UInt32)RECV_BUFFER_MAX;
 
+		args.isMultiThreads = isMultiThreads;
+		
 		if(isMultiThreads)
 			gameapp = new KBEngineAppThread(args);
 		else

KBEngineArgs.cs

@@ -35,6 +35,9 @@ public class KBEngineArgs
 		// 接收缓冲区大小
 		public MessageLengthEx RECV_BUFFER_MAX = NetworkInterface.TCP_PACKET_MAX;
 
+		// 是否多线程启动
+		public isMultiThreads = false;
+		
 		// 只在多线程模式启用
 		// 主循环tick间隔
 		public int HZ_TICK = 100;