Commit 9a25cf6f 顾剑亮

删除task

1 个父辈 1f6775d2
此文件类型无法预览
此文件类型无法预览
...@@ -43,7 +43,7 @@ namespace Asa.IOModule ...@@ -43,7 +43,7 @@ namespace Asa.IOModule
private byte[] _addressOutput; //输出地址 private byte[] _addressOutput; //输出地址
private const int SEND_SLEEP = 50; //每条命令发送的间隔 private const int SEND_SLEEP = 50; //每条命令发送的间隔
private const int PORT = 502; //端口 private const int PORT = 502; //端口
private const int UPLOAD_TIME = 3000; //5秒 private const int UPLOAD_TIME = 5000; //5秒
private Thread tRecon; //重连线程 private Thread tRecon; //重连线程
private Thread tSend; //发送命令处理 private Thread tSend; //发送命令处理
...@@ -454,7 +454,7 @@ namespace Asa.IOModule ...@@ -454,7 +454,7 @@ namespace Asa.IOModule
{ {
while (_loop) while (_loop)
{ {
Thread.Sleep(5); Thread.Sleep(10);
if (!IsConn) continue; if (!IsConn) continue;
if (_client == null) continue; if (_client == null) continue;
...@@ -520,7 +520,8 @@ namespace Asa.IOModule ...@@ -520,7 +520,8 @@ namespace Asa.IOModule
} }
Array.Copy(_stateDO, 0, staDO, 0, staDO.Length); Array.Copy(_stateDO, 0, staDO, 0, staDO.Length);
} }
System.Threading.Tasks.Task.Run(() => DO_Changed_Event?.Invoke(this, staDO)); DO_Changed_Event?.Invoke(this, staDO);
//System.Threading.Tasks.Task.Run(() => DO_Changed_Event?.Invoke(this, staDO));
} }
else if (cmd[7] == 2) //ReadDI else if (cmd[7] == 2) //ReadDI
...@@ -541,7 +542,8 @@ namespace Asa.IOModule ...@@ -541,7 +542,8 @@ namespace Asa.IOModule
} }
Array.Copy(_stateDI, 0, staDI, 0, staDI.Length); Array.Copy(_stateDI, 0, staDI, 0, staDI.Length);
} }
System.Threading.Tasks.Task.Run(() => DI_Changed_Event?.Invoke(this, staDI)); DI_Changed_Event?.Invoke(this, staDI);
//System.Threading.Tasks.Task.Run(() => DI_Changed_Event?.Invoke(this, staDI));
} }
else if (cmd[7] == 5) else if (cmd[7] == 5)
...@@ -555,7 +557,8 @@ namespace Asa.IOModule ...@@ -555,7 +557,8 @@ namespace Asa.IOModule
_stateDO[idx] = cmd[10] == 0xFF ? Box_Sta.On : Box_Sta.Off; _stateDO[idx] = cmd[10] == 0xFF ? Box_Sta.On : Box_Sta.Off;
Array.Copy(_stateDO, staDO, staDO.Length); Array.Copy(_stateDO, staDO, staDO.Length);
} }
System.Threading.Tasks.Task.Run(() => DO_Changed_Event?.Invoke(this, staDO)); DO_Changed_Event?.Invoke(this, staDO);
//System.Threading.Tasks.Task.Run(() => DO_Changed_Event?.Invoke(this, staDO));
} }
} }
...@@ -600,8 +603,8 @@ namespace Asa.IOModule ...@@ -600,8 +603,8 @@ namespace Asa.IOModule
_client = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp); _client = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
_client.SetSocketOption(SocketOptionLevel.Socket, SocketOptionName.SendTimeout, 500); _client.SetSocketOption(SocketOptionLevel.Socket, SocketOptionName.SendTimeout, 500);
_client.SetSocketOption(SocketOptionLevel.Socket, SocketOptionName.ReceiveTimeout, 500); _client.SetSocketOption(SocketOptionLevel.Socket, SocketOptionName.ReceiveTimeout, 500);
_client.SetSocketOption(SocketOptionLevel.Socket, SocketOptionName.NoDelay, true); _client.SetSocketOption(SocketOptionLevel.Socket, SocketOptionName.NoDelay, 1);
_client.NoDelay = true; //_client.NoDelay = true;
_client.Connect(IPAddress.Parse(IP), PORT); _client.Connect(IPAddress.Parse(IP), PORT);
Thread.Sleep(100); //需要等待一会才能获取连接状态 Thread.Sleep(100); //需要等待一会才能获取连接状态
IsConn = true; IsConn = true;
......
...@@ -6,3 +6,4 @@ D:\OneDrive - 上海挚锦科技有限公司\SMD\AIOBOX\AIOBOX\obj\Debug\Asa.IOM ...@@ -6,3 +6,4 @@ D:\OneDrive - 上海挚锦科技有限公司\SMD\AIOBOX\AIOBOX\obj\Debug\Asa.IOM
D:\OneDrive - 上海挚锦科技有限公司\SMD\AIOBOX\AIOBOX\obj\Debug\Asa.IOModule.AIOBOX.pdb D:\OneDrive - 上海挚锦科技有限公司\SMD\AIOBOX\AIOBOX\obj\Debug\Asa.IOModule.AIOBOX.pdb
D:\OneDrive - 上海挚锦科技有限公司\SMD\AIOBOX\AIOBOX\bin\Debug\log4net.dll D:\OneDrive - 上海挚锦科技有限公司\SMD\AIOBOX\AIOBOX\bin\Debug\log4net.dll
D:\OneDrive - 上海挚锦科技有限公司\SMD\AIOBOX\AIOBOX\obj\Debug\AIOBOX.csproj.CopyComplete D:\OneDrive - 上海挚锦科技有限公司\SMD\AIOBOX\AIOBOX\obj\Debug\AIOBOX.csproj.CopyComplete
D:\OneDrive - 上海挚锦科技有限公司\SMD\AIOBOX\AIOBOX\obj\Debug\AIOBOX.csprojAssemblyReference.cache
支持 Markdown 格式
你添加了 0 到此讨论。请谨慎行事。
Finish editing this message first!