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

 // Вызов Add во вторичном потоке.

 BinaryOp b = new BinaryOp(Add);

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

 // Выполнение другой работы в первичном потоке.…

 Console.WriteLine("В Main еще есть работа!");

 // Получение результата метода Add,

 // когда это требуется.

 int answer = b.EndInvoke(iftAR);

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

 Console.ReadLine;

}

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

Рис. 14.2. Методы, вызываемые асинхронно, выполняют свою работу в отдельном потоке

Вдобавок к уникальным хешированным значениям, вы также обнаружите, что при запуске приложения сообщение "В Main еще есть работа!" появляется практически немедленно.

<p>Синхронизация вызывающего потока</p>

Для текущей реализации Main диапазон времени между вызовом BeginInvoke и вызовом EndInvoke явно меньше пяти секунд. Поэтому после вывода на консоль сообщения "В Main еще есть работа!" поток вызова блокируется и ждет завершения существования вторичного потока, который должен получить результат метода Add. Таким образом, вы на самом деле выполняете еще один синхронный вызов.

static void Main (string[] args) {

 …

 BinaryOp b = new BinaryOp(Add);

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

 // До этого вызова проходит менее 5 секунд!

 Console.WriteLine("В Main еще есть работа!");

 // Вызывающий поток блокируется до завершения EndInvoke.

 int answer = b.EndInvoke(iftAR);

 …

}

Очевидно, что асинхронные делегаты теряют свою привлекательность, если поток вызова может при определенных условиях блокироваться. Чтобы позволить вызывающему потоку выяснить, закончил ли асинхронно вызванный метод свою работу, интерфейс IAsyncResult предлагает свойство IsCompleted. Используя этот член, поток вызова может перед вызовом EndInvoke проверить, завершен ли асинхронный вызов. Если работа метода не завершена, IsCompleted возвращает false (ложь), и поток вызова может продолжать свою работу. Если же IsCompleted возвращает true (истина), то поток вызова может получить результат "наименее блокирующим" способом. Рассмотрите следующую модификацию метода Main.

static void Main (string[] args) {

 …

 BinaryOp b = new BinaryOp(Add);

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

 // Это сообщение будет печататься до тех пор, // пока не завершится вызов метода Add.

 while (!iftAR.isCompleted) Console. WriteLine("В Main еще есть работа!");

 // Теперь мы знаем, что вызов метода Add завершен.

 int answer = b.EndInvoke(iftAR);

 …

}

Здесь вводится цикл, который будет продолжать выполнение оператора Console.WriteLine до тех пор, пока не завершится вторичный поток. Как только это произойдет, вы сможете получить результат метода Add с уверенностью, что этот метод завершил свою работу.

Вдобавок к свойству IsCompleted интерфейс IAsyncResult предлагает свойство AsyncWaitHandle для построения еще более гибкой логики ожидания. Это свойство возвращает экземпляр WaitHandle, предлагающий метод WaitOne. Преимущество метода WaitHandle.WaitOne в том, что вы можете указать максимальное время ожидания. Если указанное время превышено, WaitOne возвращает false. Рассмотрите следующий (обновленный) вариант цикла while:

while (!iftAR.AsyncWaitHandle.WaitOne(2000, true)) {

 Console.WriteLine("В Main еще есть работа!");

}

Перейти на страницу:

Похожие книги