Alienjack/AxibugEmuOnline
1
0
Fork 0
forked from sin365/AxibugEmuOnline
Code Pull Requests Activity

Compare commits

base: Alienjack:02e94317e4eb165ec02df2c4996ef01a3e5e58af
Branches Tags
Alienjack:master
Alienjack:psv_VirtualNes.Core归档
Alienjack:bak_AlphaFristLove
Alienjack:dev_beforeShader
Alienjack:dev_4VirtualNes
Alienjack:dev_basemynes
Alienjack:bak_baseOnEmulator.NES
sin365:master
sin365:dev_mame_timercount
sin365:dev_audiomix
sin365:psv_VirtualNes.Core归档
sin365:bak_AlphaFristLove
sin365:dev_beforeShader
sin365:dev_4VirtualNes
sin365:dev_basemynes
sin365:bak_baseOnEmulator.NES
sin365:beforinputsystem
..
compare: Alienjack:0783d7d90e492e993d5dc90d2d5a9bae7a55c10d
Branches Tags
Alienjack:master
Alienjack:psv_VirtualNes.Core归档
Alienjack:bak_AlphaFristLove
Alienjack:dev_beforeShader
Alienjack:dev_4VirtualNes
Alienjack:dev_basemynes
Alienjack:bak_baseOnEmulator.NES
sin365:master
sin365:dev_mame_timercount
sin365:dev_audiomix
sin365:psv_VirtualNes.Core归档
sin365:bak_AlphaFristLove
sin365:dev_beforeShader
sin365:dev_4VirtualNes
sin365:dev_basemynes
sin365:bak_baseOnEmulator.NES
sin365:beforinputsystem

No commits in common. "02e94317e4eb165ec02df2c4996ef01a3e5e58af" and "0783d7d90e492e993d5dc90d2d5a9bae7a55c10d" have entirely different histories.
02e94317e4 ... 0783d7d90e

1 changed files with 4 additions and 12 deletions
Show Stats Expand all files Collapse all files

16
AxibugEmuOnline.Client/Assets/Script/Network/NetMsg.cs
View File

@ -17,8 +17,6 @@ namespace AxibugEmuOnline.Client.Network
private NetMsg() { } private NetMsg() { }
public static object lockQueueObj = new object();
#region RegisterMsgEvent #region RegisterMsgEvent
public void RegNetMsgEvent(int cmd, Action<byte[]> callback) public void RegNetMsgEvent(int cmd, Action<byte[]> callback)
@ -63,21 +61,15 @@ namespace AxibugEmuOnline.Client.Network
#region PostEvent #region PostEvent
public void EnqueueNesMsg(int cmd, int ERRCODE, byte[] arg) public void EnqueueNesMsg(int cmd, int ERRCODE, byte[] arg)
{ {
lock (lockQueueObj) queueNetMsg.Enqueue((cmd, ERRCODE, arg));
{
queueNetMsg.Enqueue((cmd, ERRCODE, arg));
}
} }
public void DequeueNesMsg() public void DequeueNesMsg()
{ {
lock (lockQueueObj) while (queueNetMsg.Count > 0)
{ {
while (queueNetMsg.Count > 0) (int, int, byte[]) msgData = queueNetMsg.Dequeue();
{ PostNetMsgEvent(msgData.Item1, msgData.Item2, msgData.Item3);
(int, int, byte[]) msgData = queueNetMsg.Dequeue();
PostNetMsgEvent(msgData.Item1, msgData.Item2, msgData.Item3);
}
} }
} }