Страница 227 из 372
• private static readonly UInt32 _timeOut = (UInt32)0x7fffffff;
Последний параметр в вызове метода RegisterWaitForSingleObject равен false, что означает, что данная регистрация сохраняется до момента уничтожения самого свойства синхронизации.
Обработка вызова, извлекаемого из очереди вызовов
Прежде всего рассмотрим класс internal class Workltem {….. } экземпляры которого используются для хранения информации о вызовах в очереди вызовов.
Представление вызова в виде работы — экземпляра класса WorkItem
Каждый вызов представляется экземпляром класса WorkItem, в котором необходимая информация задается следующими полями:
• internal IMessage _reqMsg
Это поле хранит ссылку на объект, представляющий собственно вызов в форме сообщения. Именно в этой форме вызов передается между контекстами клиента и сервера. Соответствующий класс должен реализовать интерфейс message.
• internal IMessageSink _nextSink
Вызов попадает в контекст, пройдя некоторую цепочку перехватчиков. Перехватчик, ассоциированный со свойством синхронизации, отправляет вызов в очередь вызовов (если его нельзя выполнить сразу же). Вся семантика свойства синхронизации связана с поддержкой этой очереди. Отстояв свое время в этой очереди, вызов должен продолжить свой путь через цепочку перехватчиков. Данное поле _nextSink хранит ссылку на следующий передатчик, которому должен быть передан вызов. Интерфейс IMessageSink должен быть реализован каждым перехватчиком.
• internal IMessageSink _replySink
Вызовы разделяются на два типа: синхронные и асинхронные. В случае синхронного вызова вызывающая сторона блокируется до получения ответа, в асинхронном случае такая блокировка не выполняется. Однако, в асинхронном случае может оказаться необходимым как-то обеспечить уведомление вызывающей стороны о завершении вызова и о его результатах. В данном случае в вызов включается ссылка _replySink на специальный перехватчик, которому система должна передать уведомление. В случае синхронного вызова значение данного поля равно null.
• internal IMessage _replyMsg
В случае синхронного вызова результат отправляется вызывающей стороне опять же в форме сообщения. Данное поле будет хранить ссылку на это сообщение по завершении вызова.
• internal Context _ctx
Домен синхронизации может состоять из нескольких контекстов, и только один из них содержит свойство синхронизации данного домена. С каждым контекстом связана своя цепочка перехватчиков. В каждой такой цепочке имеется перехватчик, ассоциированный со свойством синхронизации. Вызов, перемещающийся по некоторой цепочке перехватчиков в некоторый контекст, прерывает свое путешествие в перехватчике, ассоциированном со свойством синхронизации, и отправляется в очередь вызовов в виде работы — экземпляра класса WorkItеm. Эта очередь поддерживается в свойстве синхронизации данного домена, которое может размещаться совсем не в том контексте, куда первоначально направлялся вызов. Поле _ctx используется для хранения информации о первоначальном контексте, в котором должен выполняться данный вызов после его освобождения из очереди.
• internal LogicalCallContext _callCtx
Условия выполнения вызова определяются не только контекстом, в котором он должен выполняться, но и контекстом логического вызова, сопровождающим данный вызов. Подробнее это понятие будет объяснено далее. Поле _callctx хранит ссылку на контекст логического вызова для данного вызова.
Немного про асинхронные вызовы
При разборе кода атрибута синхронизации нам придется часто упоминать такое понятие как асинхронный вызов. Уместно сделать отступление и разобрать код, демонстрирующий работу с асинхронными вызовами.
Рассмотрим следующую ситуацию. Сервер предоставляет услуги по проведению сложных математических вычислений, требующих значительных временных затрат.
При использовании синхронных вызовов клиент должен был бы последовательно вызывать необходимые методы. При этом при каждом синхронном вызове клиент блокируется до получения ответа, что не дает ему возможность вызывать методы сервера параллельно и выполнять какую-либо другую полезную работу во время ожидания результатов от сервера.
При использовании асинхронных вызовов клиент может вызывать методы сервера параллельно и в процессе ожидания выполнять дополнительную работу.
В данном случае услуги, предоставляемые сервером, сводятся к выполнению двух арифметических операций (сложение и умножение на 2). Работа, которую клиент выполняет в ожидании ответов от сервера, состоит в выводе на консоль отметок о завершении очередного 100 mс временного интервала.
using System;
using System.Threading;
using System.Runtime.Remoting;
public class Server {
public static bool Sum(int x, int y, out int z) {
Console.WriteLine(
"Server (Sum method) thread = " +
Thread.CurrentThread.GetHashCode()+
"; PoolThread = "+
Thread.CurrentThread.IsThreadPoolThread);
Thread.Sleep(1000);
z = 0;
try {
z = checked((int)(x + y));
}
catch (Exception) {
return false;
}
return true;
}
public static bool MultBy2(int x, out int y) {
Console.WriteLine {
"Server (MultBy2 method) thread = " +
Thread.CurrentThread.GetHasheode()+
"; PoolThread = "+
Thread.CurrentThread.IsThreadPoolThread);
Thread.Sleep(1000);
y = 0;
try {
у = checked((int) (x*2));
}
catch (Exception) {
return false;
}
return true;
}
}
Public class Client {
private static int workCount = 0;
private delegate bool HardFunction2Args (
int x, int y, out int result);
private delegate bool HardFunctionlArg (
int x, out int result);
private static void SumCallback(IAsyncResult ar) {
int z;
HardFunction2Args sum =
(HardFunction2Args)ar.AsyncState;
bool result = sum.Endlnvoke(out z, ar);
if (result) Console.WriteLine (
"SumCallback: Sum = " + z);
else Console.WriteLine (
"SumCallback: Bad arguments for Server.Sum
workCount++;
}
private static void MultCallback(IAsyncResult ar) {
int z;
HardFunctionlArg mult =
(HardFunctionlArg)ar.AsyncState;
bool result = mult.Endlnvoke(out z, ar);
if (result) Console.WriteLine (
"MultCallback: MultBy2 = " + z);
else Console.WriteLine (
"MultCallback: Bad argument for MultBy2");