Инструмент многопоточного программирования

  if (CoreParallel.units[index1].IsReady == 0)
                                          goto label_322;
                                      }
                                      else
                                        goto label_322;
                                    }
                                    else
                                      goto label_322;
                                  }
                                  else
                                    goto label_322;
                                }
                                else
                                  goto label_322;
                              }
                              else
                                goto label_322;
                            }
                            else
                              goto label_322;
                          }
                          else
                            goto label_322;
                        }
                        else
                          goto label_322;
                      }
                      else if (CoreParallel.units[index1].IsReady != 0)...

public class UserFormMail
       {
         public int           FromUnit=-1;  // откуда, номер юнита
         public int           ToUnit=-1;  // куда, номер юнита
         public string        Tema =null; // тема сообщения
         public string        Comment=null; // комментарий
         public string        Free=null; // свободное поле для дополнительной информации
         public Type          TypeMail=null;   // тип передаваемой информации
         public object        ContainerMail=null; // контейнер  передаваемой информации
         public object        TypeContainerMail=null; // тип контейнера
         public object        SizeContainerMail=null; // размер контейнера
         public object        FreeContainerMail=null;// свободное поле для дополнительного описания иформации и ее упаковки
         public Uri           UriMail=null; // адрес ресурса
         public Url           UrlMail=null; // Url ресурса
         public object        PathMail=null;// путь к файлу данных
         public string        Type=null;  // тип передаваемой информации
         public string        Category=null; // категория сообщения
         public object        CryptoKey=null;// ключ шифрования
         public object        CryptoAlgoritm=null; // алгоритм шифрования
         public object        CryptoMetod=null; // метод шифрования
         public long          Metka=-1;  // поле хранения уникальной метки, служит для получения единичного письма для  пользователя
         public               Func<object,object> Func=null;
         public object        FuncArgument=null;
         public object        UserData=null;  // свободное поле для размещения произвольной информации
         public  object       Mail=null; // содержание сообщения

public class UserFormMail
       {
         public int           FromUnit=-1;  // откуда, номер юнита
         public int           ToUnit=-1;  // куда, номер юнита
         public string        Tema =null; // тема сообщения
         public string        Comment=null; // комментарий
         public string        Free=null; // свободное поле для дополнительной информации
         public Type          TypeMail=null;   // тип передаваемой информации
         public object        ContainerMail=null; // контейнер  передаваемой информации
         public object        TypeContainerMail=null; // тип контейнера
         public object        SizeContainerMail=null; // размер контейнера
         public object        FreeContainerMail=null;// свободное поле для дополнительного описания иформации и ее упаковки
         public Uri           UriMail=null; // адрес ресурса
         public Url           UrlMail=null; // Url ресурса
         public object        PathMail=null;// путь к файлу данных
         public string        Type=null;  // тип передаваемой информации
         public string        Category=null; // категория сообщения
         public object        CryptoKey=null;// ключ шифрования
         public object        CryptoAlgoritm=null; // алгоритм шифрования
         public object        CryptoMetod=null; // метод шифрования
         public long          Metka=-1;  // поле хранения уникальной метки, служит для получения единичного письма для  пользователя
         public               Func<object,object> Func=null;
         public object        FuncArgument=null;
         public object        UserData=null;  // свободное поле для размещения произвольной информации
         public  object       Mail=null; // содержание сообщения

// создание письма
CoreParallel.IdentificationMail     idMail = CoreParallel.units[myUnit].unitMailSender.CreateMail();
// создание пользовательской формы
CoreParallel.UserFormMail ufm = new CoreParallel.UserFormMail();
// заполнение обязательных полей
ufm.FromUnit=myUnit;  
ufm.ToUnit=0;
ufm.Mail= (object) ”Это текст письма”
// прикрепление  формы к письму
CoreParallel.units[myUnit].unitMailSender.SetUserDataMail(idMail.IdNumberMail,ufm);
// отправка письма в ящик юнита адресата   
 CoreParallel.units[myUnit].unitMailSender.SendMail(idMail);

// объявляется массив форм письма
CoreParallel.UserFormMail[] ufmArray = new CoreParallel.UserFormMail[1];
// создается форма одного письма или нескольких для пакетной рассылки
CoreParallel.UserFormMail    ufm = new CoreParallel.UserFormMail();
// в каждой форме заполняются обязательные поля
ufm.FromUnit=myUnit;  
ufm.ToUnit=id3; 
// в массив форм добавляется конкретное письмо или несколько
ufmArray[0]=ufm;
// отправляется пачка писем от юнита myUnit различным адресатам в ассинхронном режиме
CoreParallel.units[myUnit].unitMailSender.SetAndSendUserDataMailArray(ufmArray,0);
//public   void  SetAndSendUserDataMailArray( UserFormMail[] userFormMailArray , int mode )//  mode=0 - асинхроный режим

public  void  WaitMail (int myUnit);

public string        Type=null;  // тип передаваемой информации

// Выполнить метод типа  Func<object,object>  в потокобезопасном режиме синхронно.
public object RunMetodSync(  Func<object,object>  func,  object argument)
 
//Выполнить метод типа  Func<object,object>  в потокобезопасном режиме асинхронно
public void RunMetodAsync(  Func<object,object> func,object argument)
 
//Выполнить метод синхронно и уничтожить сохраненный аргумент
//Метод аналогичен RunMetodSync, после исполнения метода автоматически 
//уничтожается сохраненный аргумент метода, указанный с помощью  int index.
 
public object RunMetodSyncSafe(  Func<object,object> func,object argument, int index)   
 
//Аналогичен  RunMetodSyncSafe, выполняется асинхронно. Для этого метода 
//предварительное сохранение аргумента, а если он сложный, то и его отдельных
// частей, крайне желательно.
public void RunMetodAsyncSafe(  Func<object,object> func,object argument,int index)

static int X=0;
pablic int SummaUnSafe(int arg) {X=X+arg; return   X;} 
 
//в потокобезопасном варианте должен быть преобразован  к виду
pablic object Summa(object arg) {X=X+  (int)  arg; return  (object)  X;}  
// метод размещен в классе ClassForSumma
//Обращение к методу  int Y= summaUnSafe(100); заменяется шаблонным 
//вызовом метода класса RunMetod.
Int arg=100; 
object argument = (object)arg; // запаковали входной аргумент.
Func<object,object> summa = ClassForSumma.Summa; // получили экземпляр метода Summa
// шаблонный вызов метода в потокобезопасном режиме.
 CoreParallel.units[myUnit].unitRunMetod.RunMetodSync( summa,  argument);
//CoreParallel – класс исполнительной системы, поскольку метод
 //статический указывается название класса, а не его экземпляр, например, myCoreParallel;
//units[myUnit] – коллекция юнитов;
//myUnit – фактический параметр, передающийся в метод юнита при его исполнении.
//unitRunMetod.RunMetodSync – экземпляр метода класса RunMetod;
//summa -  экземпляр исполняемого метода;
//argument- аргумент метода summa, в данном случае число 100.

public void RunMetodAsyncSafe(  Func<object,object> func,object argument,int index)

CoreParallel.units[myUnit].musor.Add(new System.Collections.Generic.List<object>());      
//и определяется место хранения
int index=  CoreParallel.units[myUnit].musor.Count-1;

       CoreParallel.units[myUnit].musor[index].Add(argument);

//Пусть имеется популярный метод 
public  string MessageBox.Show(string  str);
//Заворачиваем его в обертку 
Public object My_MessageBoxShow(object arg)
{   string str = (string)arg;
MessageBox.Show(str);
return null;
}

public object RunMetodSyncSafe

public  object Synchronous (   Func<object>  func)  
public  object Asynchronous (   Func<object>  func)

object RunMetodSync(  Func<object,object>  func,  object argument)

int  SetArgumentToServer (int unit,  int numMetod,  object Argument)

object SetArgumentToServerThread(object input)

 object[] argument = new  object[2];            // массив переменных типа object
 argument[0]= (object) unSortedArray;      // исходный массив
 argument[1]= (object) sortedArray;           // отсортированный массив

object  arg = (object) argument;

 object unitMetod2( object myArgument )
{ object[] argument =(object[]) myArgument; // привели аргумент к виду массива объектов
  Int[] unSortedArray = (int []   )  myArgument[0];  // получили ссылку на первый массив значений
  Int[].sortedArray = (int [] )    myArgument[0];       // получили ссылку на второй массив значений
}

object SetArgumentToServerThread(object arg)

int unit,  int numMetod,  object Argument

object[] argument1= new  object[3];        // массив переменных типа object
 argument1[0]= (object) unit;                      // номер юнита
 argument1[1]= (object) numMetod ;      // номер метода юнита
argument1[2]= (object) Argument ;           // ранее  упакованный аргумент метода юнита
 
object endArgument = (object) argument1;  //  конечный аргумент

object RunMetodSync(  Func<object,object>  func, object argument)

 CoreParallel.units[myUnit].unitRunMetod.RunMetodSync
                                           (SetArgumentToServerThread , endArgument);

public object Synchronous( 
Func<object,object,object,object,object   ,object   ,object  ,object, object  , object , object  , object, object  , object, object, object, object>   func,
 
object argument1,     object argument2,     object argument3,     object argument4   ,
object argument5,     object argument6 ,    object argument7,     object argument8  ,
object argument9,     object argument10 ,  object argument11 ,  object argument12 ,
object argument13 ,  object argument14 ,  object argument15 ,  object argument16)

object[] argument = new  object[2];            // массив переменных типа object
argument[0]= (object) unSortedArray;      // исходный массив
argument[1]= (object) sortedArray;           // отсортированный массив
object arg = (object) argument;

CoreParallel. units[myUnit]. unitRunMetod. Synchronous 
        (  SetArgumentToServerDirectArgument,   unitManager,  2 , argument );

Int unit= (int) argument1;
Int numberMetod = (int) ) argument2;
object  argumentForMetodF2= argument3;  -без преобразования типа, т.к. аргумент уже имеет  
                                                                  //                тип object.

int Summa(int x, int y) { return x+y;  }

object Summa(object x, object y)
 {int myX= (int)x;     int myY= (int)y;  return (object) (myX + myY);}.

Int  z = (int)   Summa(10, 20);

Int z=  (int )  CoreParallel. units[myUnit]. unitRunMetod. Synchronous (Summa   ,  10,  20);

object    MySumma(object x, object y)
  {   int myX= (int)x;     int myY= (int)y;
      return (object) Summa(int myX, myY   );
   }
//Вызываем оболочку
Int z=  (int )  CoreParallel. units[myUnit]. unitRunMetod. Synchronous (MySumma   ,  10,  20);.

public object Synchronous( 
Func<object,object,object,object,object   ,object   ,object  ,object, object  , object , object  , object, object  , object, object, object, object>   func,
 
object argument1,     object argument2,     object argument3,     object argument4   ,
object argument5,     object argument6 ,    object argument7,     object argument8  ,
object argument9,     object argument10 ,  object argument11 ,  object argument12 ,
object argument13 ,  object argument14 ,  object argument15 ,  object argument16)

// метод  с  2 аргументами
Int z=  (int )  CoreParallel. units[myUnit]. unitRunMetod. Synchronous (Summa2   ,  10,  20);
 
// метод с 3 аргументами
Int z=  (int )  CoreParallel. units[myUnit]. unitRunMetod. Synchronous (Summa3   ,  10,  20, 30);
//  …..
 
// метод с 16 аргументами
Int z=  (int )  CoreParallel. units[myUnit]. unitRunMetod. Synchronous 
    (Summa16   ,  10,  20, 30,40, 50, 60, 70, 80, 90, 100, 110, 120, 130, 140, 150, 160);
// метод без аргументов и возвращаемого значения
CoreParallel. units[myUnit]. unitRunMetod. Synchronous (OneArgumentMetod);
 
// метод без аргументов  с возвращаемым значением
Int z=  (int )  CoreParallel. units[myUnit]. unitRunMetod. Synchronous (Summa0)