Эндрю Троелсен - ЯЗЫК ПРОГРАММИРОВАНИЯ С# 2005 И ПЛАТФОРМА .NET 2.0. 3-е издание

namespace AsyncCallbackDelegate {

public delegate int BinaryOp(int x, int y);

class Program {

static void Main(string[] args) {

Console.WriteLine("*** Пример делегата AsyncCallback ***");

Console.WriteLine("Вызван Main() в потоке {0}", Thread.CurrentThread.GetHashCode());

BinaryOp b = new BinaryOp(Add);

IAsyncResult iftAR = b.BeginInvoke(10, 10, new AsyncCallback(AddComplete), null);

// Здесь выполняется другая работа…

Console.ReadLine();

}

static void AddComplete(IAsyncResult iftAR) {

Console.WriteLine("Вызван AddComplete() в потоке {0}", Thread.CurrentThread.GetHashCode());

Console.WriteLine("Ваше сложение выполнено");

}

static int Add(int x, int y) {

Console.WriteLine("Вызван Add() в потоке {0}.", Thread.CurrentThread.GetHashCode());

Thread.Sleep(5000);

return x + y;

}

}

}

Снова заметим, что статический метод AddComplete() будет вызван делегатом AsyncCallback тогда, когда завершится вызов метода Add(). Выполнение этой программы может подтвердить, что именно вторичный поток выполняет обратный вызов AddComplete() (рис. 14.3).

Рис. 14.3. Делегат AsyncCallback в действии

В текущей своей форме метод Main() не хранит тип IAsyncResult, возвращаемый из BeginInvoke(), и не вызывает EndInvoke(). Более того, целевой метод делегата AsyncCallback (в данном случае это метод AddComplete()) вообще не имеет доступа к оригинальному делегату BinaryOp, созданному в контексте Main(). Можно, конечно, объявить BinaryOp, как статический член класса, чтобы позволить обоим методам иметь доступ к объекту, но более "элегантным" решением яв-ляетcя использование входного параметра IAsyncResult.

Поступающий на вход параметр IAsyncResult, передаваемый целевому методу делегата AsyncCallback, является экземпляром класса AsyncResult (заметьте, префикс I здесь отсутствует), определенного в пространстве имен System.Runtime. Remoting.Messaging. Статическое свойство AsyncDelegate возвращает ссылку на оригинальный асинхронный делегат, созданный где-то в программе. Таким образом, чтобы получить ссылку на объект делегата BinaryOp, размещенный в Main(), нужно просто преобразовать возвращенный свойством AsyncDelegate тип System.Object в тип BinaryOp. После этого можно вызвать EndInvoke(), как и ожидается.

// Не забудьте добавить директиву 'using' для

// System.Runtime.Remoting.Messaging!

static void AddComplete(IAsyncResult iftAR) {

Console.WriteLine("Вызван AddComplete() в потоке {0}.", Thread.CurrentThread.GetHashCode());

Console.WriteLine("Ваше сложение выполнено");

// Теперь получим результат.

AsyncResult ar = (AsyncResult)itfAR;

BinaryOp b = (BinaryOp)ar.AsyncDelegate;

Console.WriteLine("10 + 10 равно {0}.",

b.EndInvoke(itfAR));

}

Заключительным аспектом нашего рассмотрения асинхронных делегатов будет обсуждение последнего из аргументов метода BeginInvoke() (этот аргумент у нас до сих пор был равен null). С помощью этого параметра можно передать в метод обратного вызова дополнительную информацию состояния из первичного потока. Ввиду того, что прототипом этого аргумента является System.Object, с его помощью можно передать практически любые данные, приемлемые для метода обратного вызова. Предположим для примера, что первичный поток должен передать методу AddComplete() пользовательское текстовое сообщение.

static void Main(string[] args) {

…

IAsyncResult iftAR = b.BeginInvoke(10, 10, new AsyncCallback(AddComplete), "Main() благодарит вас за сложение этих чисел.");

…

}

Чтобы получить эти данные в контексте AddComplete(), используйте свойство AsyncState поступающего на вход параметра IAsyncResult.

static void AddComplete(IAsyncResult iftAR) {

…

// Получение объекта с информацией и преобразование его в строку.

string msg = (string)itfAR.AsyncState;

Console.WriteLine(msg);

}

На рис. 14.4 показан вывод этого приложения.

Рис. 14.4. Передача и получение пользовательских данных состояния

Чудесно! Теперь, когда вы понимаете, что делегат .NET можно использовать для автоматического запуска вторичного потока выполнения, обрабатывающего асинхронный вызов метода, давайте обратим внимание на возможности непосредственного взаимодействия о потоками с помощью пространства имен System.Threading.

Исходный код. Проект AsyncCallbackDelegate размещен в подкаталоге, соответствующем главе 14.