Почему использование модели асинхронного программирования в .Net не приводит к исключениям StackOverflow? - PullRequest
Новая
       18

Почему использование модели асинхронного программирования в .Net не приводит к исключениям StackOverflow?

5 голосов
/ 14 января 2011

Например, мы вызываем BeginReceive и имеем метод обратного вызова, который BeginReceive выполняет после его завершения. Если этот метод обратного вызова снова вызывает BeginReceive в моем уме, это будет очень похоже на рекурсию. Как это, что не вызывает исключение переполнения стека. Пример кода из MSDN: 

private static void Receive(Socket client) {
    try {
        // Create the state object.
        StateObject state = new StateObject();
        state.workSocket = client;

        // Begin receiving the data from the remote device.
        client.BeginReceive( state.buffer, 0, StateObject.BufferSize, 0,
            new AsyncCallback(ReceiveCallback), state);
    } catch (Exception e) {
        Console.WriteLine(e.ToString());
    }
}

private static void ReceiveCallback( IAsyncResult ar ) {
    try {
        // Retrieve the state object and the client socket 
        // from the asynchronous state object.
        StateObject state = (StateObject) ar.AsyncState;
        Socket client = state.workSocket;

        // Read data from the remote device.
        int bytesRead = client.EndReceive(ar);

        if (bytesRead > 0) {
            // There might be more data, so store the data received so far.
        state.sb.Append(Encoding.ASCII.GetString(state.buffer,0,bytesRead));

            // Get the rest of the data.
            client.BeginReceive(state.buffer,0,StateObject.BufferSize,0,
                new AsyncCallback(ReceiveCallback), state);
        } else {
            // All the data has arrived; put it in response.
            if (state.sb.Length > 1) {
                response = state.sb.ToString();
            }
            // Signal that all bytes have been received.
            receiveDone.Set();
        }
    } catch (Exception e) {
        Console.WriteLine(e.ToString());
    }
}

Ответы [ 4 ]

3 голосов
/ 14 января 2011

BeginReceive регистрирует функцию обратного вызова, связанную с перекрывающейся операцией ввода-вывода.Обратный вызов будет вызываться операционной системой, когда данные доступны, но вызов BeginReceive немедленно возвращается, и поэтому ваш вызов ReceiveCallback также завершается.
Думайте о реальном вводе-выводе как происходящем в потоке, который не принадлежитВы, а скорее в ОС.Ваш акт регистрации обратного вызова просто говорит «продолжайте звонить мне, когда что-то происходит», но он не добавляется в стек.Вот почему это называется асинхронным.

3 голосов
/ 14 января 2011

Интересный вопрос, но после того, как вы вызовете BeginReceive, ваша функция продолжает выполняться, а затем, в конце концов, возвращается, поэтому реальной рекурсии там нет.

2 голосов
/ 14 января 2011

Поскольку BeginReceive вызывает другой произвольный поток - каждый поток содержит свой собственный стек. Несмотря на то, что выполняется один и тот же код, стек никогда не становится достаточно глубоким в данном потоке, чтобы вызвать исключение. Стек раскручивается, если вызов через другой поток неблокируемый - он делает вызов затем обычным. Вы бы получили проблемы, если бы каждый из них ждал, но не вернулся.

В вашем примере, в зависимости от пути кода - он может работать вечно. Идея аналогична сопрограммам, где методы постоянно вызывают друг друга в грубом стиле пинг-понга, но опять же нет проблем со стеком.

1 голос
/ 14 января 2011

Использование 

client.BeginReceive(state.buffer,0,StateObject.BufferSize,0, 
    new AsyncCallback(ReceiveCallback), state);

не не автоматически вызывает метод ReceiveCallback, этот метод вызывается после завершения операции.

Тем временем метод, который вызвал BeginReceive, продолжает выполняться, делать то, что он делает, и возвращаться счастливо, таким образом удаляя себя из стека.

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

...