Send data asynchronously using the thread pool

使用线程池异步发送数据
qiedebeiai · Jan 11, 2018 · f58d219 · f58d219
1 parent 5d049f6
commit f58d219
Show file tree

Hide file tree

Showing 3 changed files with 16 additions and 14 deletions.
diff --git a/README.md b/README.md
@@ -30,13 +30,16 @@ Note: connectId (guid) represents a connection object, data (byte []), success (
 * 4. Send a message  
 > Server server.Send (connectId, data, offset, length);  
 > Client client.Send (data, offset, length);  
-* 5. Triggered receive events  
+* 5. Trigger sent events  
+> Server server.OnSend (connectId, length);  
+> Client client.OnSend (length);   
+* 6. Triggered receive events  
 > Server server.OnReceive (connectId, data);   
 > Client client.OnReceive (data);   
-* 6. Close the connection   
+* 7. Close the connection   
 > Server server.Close (connectId);   
 > Client client.Close ();   
-* 7. Trigger to close the connection event   
+* 8. Trigger to close the connection event   
 > Server server.OnClose (connectId);   
 > Client client.OnClose ();   
 
@@ -91,13 +94,16 @@ Paket CLI:paket add socket.core
 * 4.发送消息   
 	>服务端 server.Send(connectId,data,offset,length);  
 	>客户端 client.Send(data,offset,length);
-* 5.触发接收事件  
+* 5.触发已发送事件   
+	>服务端 server.OnSend(connectId,length);   
+	>客户端 client.OnSend(length);  
+* 6.触发接收事件    
 	>服务端 server.OnReceive(connectId, data);  
 	>客户端 client.OnReceive(data);  
-* 6.关闭连接  
+* 7.关闭连接  
 	>服务端 server.Close(connectId);   
 	>客户端 client.Close();   
-* 7.触发关闭连接事件   
+* 8.触发关闭连接事件   
 	>服务端 server.OnClose(connectId);   
 	>客户端 client.OnClose();    
 

diff --git a/socket.core/Client/TcpClients.cs b/socket.core/Client/TcpClients.cs
@@ -123,9 +123,7 @@ internal void Connect(string ip, int port)
             {
                 ProcessConnect(connSocketAsyncEventArgs);
             }
-            //发送线程池
-            ThreadPool.SetMinThreads(1, 1);
-            ThreadPool.SetMaxThreads(workingThreadNumber, workingThreadNumber);
+            //发送线程池        
             for (int i = 1; i <= workingThreadNumber; i++)
             {
                 ThreadPool.QueueUserWorkItem(new WaitCallback(StartSend));
@@ -246,7 +244,7 @@ private void StartSend(object obj)
                 }
                 else
                 {
-                    Thread.Sleep(20);
+                    Thread.Sleep(2);
                 }
             }
         }

diff --git a/socket.core/Server/TcpServer.cs b/socket.core/Server/TcpServer.cs
@@ -144,9 +144,7 @@ internal void Start(int port)
             listenSocket.Listen(1000);
             //在监听套接字上接受
             StartAccept(null);
-            //发送线程池
-            ThreadPool.SetMinThreads(1, 1);
-            ThreadPool.SetMaxThreads(workingThreadNumber, workingThreadNumber);
+            //发送线程池           
             for (int i = 1; i <= workingThreadNumber; i++)
             {
                 ThreadPool.QueueUserWorkItem(new WaitCallback(StartSend), i.ToString());
@@ -320,7 +318,7 @@ private void StartSend(object obj)
         /// <param name="length">长度</param>
         internal void Send(Guid connectId, byte[] data, int offset, int length)
         {
-            sendQueue.Enqueue(new SendingQueue() { connectId = connectId, data = data, offset = offset, length = length });
+            sendQueue.Enqueue(new SendingQueue() { connectId = connectId, data = data, offset = offset, length = length });            
         }
 
         /// <summary>