Блог

У меня есть эта устаревшая сторонняя COM-библиотека DLL. Я зарегистрировал его в реестре и добавил RCW в свое консольное приложение .NET / C #. В реестре модель потоков для COM отображается как квартира. Вся цель моего приложения — одновременно отправлять несколько запросов и получать ответы на этот COM-сервер, используя многопоточность.

Я использую SmartThreadPool для управления потоками, и теперь в каждом потоке я создаю новые объекты для шагов поиска / отправки запросов COM. Однако, все же, если я посмотрю на ЖУРНАЛ COM-СЕРВЕРА, запросы отправляются / обрабатываются последовательно.

В чем проблема?

Итак, я считаю, что проблема заключается в том, что COM настроен как квартира / STA. Но моя конечная цель — заставить его работать, поэтому мои вопросы,

1. Предположим, что все, что у меня есть в моем распоряжении, это DLL-файл STA COM, есть ли какие-либо обходные пути, которые я могу заставить его обрабатывать мои запросы параллельно?

2. Учтите тот факт, что когда я запускаю два экземпляра моего консольного приложения параллельно, журналы на конечной серверной машине (с которой фактически подключается и работает COM DLL) фактически показывают, что запросы от двух экземпляров обрабатываются параллельно в двух разных сеансах. Таким образом, конечное приложение полностью ориентировано на поддержку параллельной обработки. (И я думаю, это детский вопрос) Предположим, я могу получить доступ к COM-коду, будет ли легко заставить его поддерживать MTA?

[Это действительно становится слишком запутанным, и я схожу с ума! Пожалуйста, обратите внимание, что каждый из потоков создает свой собственный набор новых объектов из файла DLL COM для поиска на COMServer, запроса, отправки и т.д.]

Код приложения

 public class start
{
    public static void Main(string[] args)
    {
         StartProcessing();
    }

    private static void StartProcessing()
    {
        CoreProcessor pcr = new CoreProcessor();
        pcr.start();
    }
}

public class CoreProcessor
{
    public static ManualResetEvent IsAllDone;
    public static int NumberOfActiveThreads;
    private SmartThreadPool TPool = new SmartThreadPool();
    public void start()
    {
        IEnumerable<string> LstRequests = FileIO.GetAllRequestFileNames();
        NumberOfActiveThreads = LstRequests.Count();
        IsAllDone = new ManualResetEvent(false);
        foreach(var reqName in LstRequests)
        {
            ReqInfo req = new ReqInfo(){RequestPath = reqName;};
            TPool.QueueWorkItem(new WorkItemCallBack(req.ProcessRequest));
        }
        if(NumberOfActiveThreads  > 0)
            IsAllDone.WaitOne();
    }
}

public class ReqInfo
{
    public string RequestPath;
    public void ProcessRequest()
    {
         ABC_COM_Request req = new ABC_COM_XMLUTIL().CreateRequest();
         ABC_COM_Server svr = new ABC_COM_ServerLookup().lookup("serverhostname", 1099);
         ABC_COM_Response resp = svr.submit(req);
         if (InterLocked.Decrement(ref CoreProcessor.NumberOfActiveThreads) == 0)
                     CoreProcessor.IsAllDone.Set();
    }
}
  

Если все, что у вас есть, это компонент COM, и он является компонентом STA, то вы ничего не можете сделать, чтобы экземпляр этого компонента вызывал службы одновременно.

Однако это не мешает вам создавать несколько экземпляров компонента и выполнять вызовы для нескольких экземпляров. С этой целью вы можете рассмотреть возможность использования пула объектов COM и получить свои экземпляры компонента таким образом.

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

Предполагая, что вы можете получить доступ к коду, невозможно сказать, что потребуется для его запуска в MTA или free-threaded (последнее предпочтительнее); мы не знаем деталей реализации или состояния, которое сохраняется (или на что похож API).

Если все, что делает компонент, это отправляет запросы и обрабатывает ответы без сохранения состояния, тогда это должно быть довольно просто, это просто вопрос переключения квартиры.

Однако есть две причины, по которым компонент может быть STA:

1) Компонент имеет много состояний, и STA был способом убедиться, что состояние не было повреждено при одновременных вызовах; в этом случае ваша работа по созданию компонента MTA / free-threading будет сложной, так как вам придется все защищать, и даже тогда вы можетене получите никаких преимуществ из-за всех проверок параллелизма, которые вам, возможно, придется выполнить (хотя вы можете найти способ преобразовать код в .ЧИСТЫЙ код, таким образом, который легко потокобезопасен).

2) Компонент был написан на VB6 или языке, который не поддерживает компоненты MTA / free-threaded; в этом случае невозможно изменить модель квартиры, и вам придется либо иметь несколько экземпляров, либо выполнить преобразование в .СЕТЬ, которая является потокобезопасной.

Вероятно, вам потребуется создать несколько потоков STA, каждый со своим собственным циклом сообщений (*), и каждый со своим собственным экземпляром COM-объекта с общим потоком.

Вы можете установить базовое состояние потока, вызвав Thread .SetApartmentState.

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