High CPU% при использовании делегата

Question

я бегу следующий кусок кода, который использует делегат для возврата асинхронного сетевого потока:

static void Main(string[] args) 
{ 
    NetworkStream myNetworkStream; 
    Socket socket; 
    IPEndPoint maxPort = new IPEndPoint(IPAddress.Parse("xxx.xxx.xxx.xxx"), xxxx); 

    socket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.IP); 
    socket.Connect(maxPort); 

    myNetworkStream = new NetworkStream(socket); 

    byte[] buffer = new byte[1024]; 
    int offset = 0; 
    int count = 1024; 

    string Command = "LOGIN,,,xxxx\n"; 
    ASCIIEncoding encoder = new ASCIIEncoding(); 

    myNetworkStream.BeginRead(buffer, offset, count, new AsyncCallback(OnBeginRead), myNetworkStream); 
    myNetworkStream.Write(encoder.GetBytes(Command), 0, encoder.GetByteCount(Command)); 

    while (true) { } 
} 

public static void OnBeginRead(IAsyncResult ar) 
{ 
    NetworkStream ns = (NetworkStream)ar.AsyncState; 
    int bufferSize = 1024; 
    byte[] received = new byte[bufferSize]; 

    ns.EndRead(ar); 

    int read; 

    while (true) 
    { 
     if (ns.DataAvailable) 
     { 
      string result = String.Empty; 

      read = ns.Read(received, 0, bufferSize); 
      result += Encoding.ASCII.GetString(received); 
      received = new byte[bufferSize]; 

      result = result.Replace(" ", ""); 
      result = result.Replace("\0", ""); 
      result = result.Replace("\r\n", ","); 

      Console.WriteLine(result); 
     } 
    } 
} 

Это работает, но мое использование CPU через крышу (50% на Intel Core i3), поэтому, очевидно, я делаю это неправильно, но как это сделать?

Благодаря

Answer 1

Вы только чтение самого первых байт асинхронно, после чего вы оказываетесь в бесконечном цикле с синхронизацией операций чтения в методе OnBeginRead (это путаное имя BTW). В то же время эти первые байты отбрасываются в вашем текущем коде.

Вы должны обработать данные после EndRead (который является функцией, возвращающей сколько байт были прочитаны в буфер в этой асинхронной операции), а затем начать другую асинхронное чтение с BeginRead и возвратом (нет зацикливания в асинхронном код!).

Edited добавить образец, показывающий, как асинхронная чтение будет работать:

internal class StreamHelper { 
    private readonly NetworkStream stream; 
    private readonly byte[] buffer = new byte[1024]; 

    public StreamHelper(Socket socket) { 
     stream = new NetworkStream(socket); 
    } 

    public NetworkStream Stream { 
     get { 
      return stream; 
     } 
    } 

    public byte[] Buffer { 
     get { 
      return buffer; 
     } 
    } 
} 

private static void Main(string[] args) { 
    IPEndPoint maxPort = new IPEndPoint(IPAddress.Parse("xxx.xxx.xxx.xxx"), 100); 

    Socket socket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.IP); 
    socket.Connect(maxPort); 

    StreamHelper helper = new StreamHelper(socket); 
    helper.Stream.BeginRead(helper.Buffer, 0, helper.Buffer.Length, StreamReadCallback, helper); 

    string Command = "LOGIN,,,xxxx\n"; 
    byte[] bytes = Encoding.ASCII.GetBytes(Command); 
    // note: the write isn't async, but should maybe be converted as well 
    helper.Stream.Write(bytes, 0, bytes.Length); 

    Console.ReadLine(); // wait for a return key press 
} 

private static void StreamReadCallback(IAsyncResult ar) { 
    StreamHelper helper = (StreamHelper)ar.AsyncState; 
    // note: EndRead will throw an exception if something went wrong - you should deal with that 
    int bytesRead = helper.Stream.EndRead(ar); 
    if (bytesRead > 0) { 
     string charsRead = Encoding.ASCII.GetString(helper.Buffer, 0, bytesRead); 
     Console.Write(charsRead); 
     helper.Stream.BeginRead(helper.Buffer, 0, helper.Buffer.Length, StreamReadCallback, helper); 
    } 
} 

Answer 2

Вы постоянно зацикливание на главной теме:

while (true) { } 

Это приводит к тому, процессорное ядро ​​этой нити на полную мощность в любое время. Попробуйте спать, чтобы предотвратить нить от принятия процессорного времени излишне:

while (true) { Thread.Sleep(5000); } 

Answer 3

Возможно заменить неэффективность спиннинга процессора в нижней части основного метода из

while (true) { } 

в

Console.ReadLine(); 

Кстати, Лусеро находится на месте. Вы переходите в цикл infinte (в OnBeginRead) с потоком, который вызывает метод обратного вызова. Это кажется неправильным. Обратные вызовы должны обрабатываться как можно скорее, чтобы обработать вызывающий поток. Обычно вы извлекаете данные в обратном вызове и отправляете сигнал в свой поток, чтобы обработать остальные. Возможно, здесь будет использоваться поток TPL.