7

Здравствуйте, большое спасибо всем, кто отвечает!

Вот и я сам добрался до момента, когда не могу разобраться, прошу вашей помощи. Имеется такой код: в двух словах, приложение подключается к биржевой программе, которая по средствам RTD interface в реальном времени отдает данные о котировках и их обновлении, проблема как раз в обновлении.

Извне вызывается моя функция UpdateNotify() класса RtdUpdate.

  1. Как правильно построить логику передачи управления внутри приложения, при условии вызова одной из функций извне?
  2. В каком месте следует передавать выполнение кода в новый поток при том же условии (вызов одной из функций извне)?
  3. Что стоит учесть при написании функций, которые вызываются извне?

Имеется такой код:

 <code>
 public partial class Form1 : Form
     {
    //создаем переменную типа RtdClient
    RtdClient rtdClient;
    //создаем переменную типа updateNotification
    RtdUpdate rtdUpdate;
    //конструктор Form1
    public Form1()
    {
        InitializeComponent();
        var tosClassId = new Guid(Registry.GetValue(@"HKEY_LOCAL_MACHINE\SOFTWARE\Classes\myapp.COMApp.1\CLSID\", "", null).ToString());
        rtdClient = new RtdClient(tosClassId, this);
        //отправляем ссылку на наш клиент, для обновлений
        rtdUpdate = new RtdUpdate(ref rtdClient);
        //подписываем наш клиент на обновления
        rtdClient.StartListenUpdate(ref rtdUpdate);
    }

    //функция, обновляет значения в массивах, если пришло update
    public void UpdateOnePrice(object _inputSendDataToThread)
    {
        /* тут код который анализирует обновление */
    }

    //класс реализует RtdClient
    public class RtdClient
    {
        Form1 form;
        Type rtd;
        IRtdServer server;


        public RtdClient(Guid _serverId, Form1 _form)
        {
            form = _form;
            rtd = Type.GetTypeFromCLSID(_serverId);
            server = (IRtdServer)Activator.CreateInstance(rtd);
        }

        public void StartListenUpdate(ref RtdUpdate _rtdUpdate)
        {
            server.ServerStart(_rtdUpdate);
        }

        public void updateData()
        {
            try
            {
                var refresh = server.RefreshData(1);

                if (refresh.Length > 0)
                {
                    sendDataToThread send = new sendDataToThread();
                    send.data[0, 0] = refresh[0, 0];
                    send.data[1, 0] = refresh[1, 0];
                    form.UpdateOnePrice(send);
                }
            }
            catch (Exception ex)
            {
                // TODO: Log exception
                MessageBox.Show("error:" + ex);
            }
        }

    }


    public class RtdUpdate : IRTDUpdateEvent
    {
        RtdClient rtdClient = null;
        ThreadManager threadManager;

        public delegate void MethodContainer();

        public RtdUpdate(ref RtdClient _rtdClient)
        {
            rtdClient = _rtdClient;
            threadManager = new ThreadManager();
        }


        public void UpdateNotify()
        {
            //узнаем номер свободного потока
            int numThread = -1;
            while (numThread < 0)
            {
                numThread = threadManager.FreeThreadPlz();
            }
            //запускаем обновление в свободном потоке
            threadManager.threads[numThread] = new Thread(new ThreadStart(rtdClient.updateData));
            threadManager.threads[numThread].Start();
        }
    }

    //класс для того, чтобы описать, то что передаем в новый поток
    public class sendDataToThread
    {
        public object[,] data = new object[2, 1];
    }

    //класс который реализует управление потоками
    public class ThreadManager
    {
        //кол-во разрешенных потоков 
        int threadCount = 10;

        //массив с рабочими потоками
        public Thread[] threads = new Thread[10];

        //какой поток сейчас свободен
        public int FreeThread = 0;

        //конструктор
        public ThreadManager()
        {
            Array.Resize(ref threads, threadCount);
        }

        public int FreeThreadPlz()
        {
            int i = 0;
            for (i = 0; i < threadCount; i++)
            {
                try
                {
                    if (!threads[i].IsAlive)
                    {
                        return i;
                    }
                }
                catch (Exception)
                {
                    return i;
                }
            }
            /*
               LOG TO all BUSY THREAD 
             */

            return -1;
        }
    }
    //ниже описание интерфейсов
    [ComImport, TypeLibType((short)0x1040), Guid("EC0E6191-DB51-11D3-8F3E-00C04F3651B8")]
    public interface IRtdServer
    {
        [MethodImpl(MethodImplOptions.InternalCall, MethodCodeType = MethodCodeType.Runtime), DispId(10)]
        int ServerStart([In, MarshalAs(UnmanagedType.Interface)] IRTDUpdateEvent callback);

        [return: MarshalAs(UnmanagedType.Struct)]
        [MethodImpl(MethodImplOptions.InternalCall, MethodCodeType = MethodCodeType.Runtime), DispId(11)]
        object ConnectData([In] int topicId, [In, MarshalAs(UnmanagedType.SafeArray, SafeArraySubType = VarEnum.VT_VARIANT)] ref object[] parameters, [In, Out] ref bool newValue);

        [return: MarshalAs(UnmanagedType.SafeArray, SafeArraySubType = VarEnum.VT_VARIANT)]
        [MethodImpl(MethodImplOptions.InternalCall, MethodCodeType = MethodCodeType.Runtime), DispId(12)]
        object[,] RefreshData([In, Out] ref int topicCount);

        [MethodImpl(MethodImplOptions.InternalCall, MethodCodeType = MethodCodeType.Runtime), DispId(13)]
        void DisconnectData([In] int topicId);

        [MethodImpl(MethodImplOptions.InternalCall, MethodCodeType = MethodCodeType.Runtime), DispId(14)]
        int Heartbeat();

        [MethodImpl(MethodImplOptions.InternalCall, MethodCodeType = MethodCodeType.Runtime), DispId(15)]
        void ServerTerminate();
    }

    //[ComImport, TypeLibType((short)0x1040), Guid("A43788C1-D91B-11D3-8F39-00C04F3651B8")]
    public interface IRTDUpdateEvent
    {
        [MethodImpl(MethodImplOptions.InternalCall, MethodCodeType = MethodCodeType.Runtime), DispId(10), PreserveSig]
        void UpdateNotify();

        /*
        [DispId(11)]
        int HeartbeatInterval
        {
            [MethodImpl(MethodImplOptions.InternalCall, MethodCodeType = MethodCodeType.Runtime), DispId(11)]
            get;
            [param: In]
            [MethodImpl(MethodImplOptions.InternalCall, MethodCodeType = MethodCodeType.Runtime), DispId(11)]
            set;
        }
        */

        [MethodImpl(MethodImplOptions.InternalCall, MethodCodeType = MethodCodeType.Runtime), DispId(12)]
        void Disconnect();
    }
}

16
  • 7
    Окей. Вам придётся сообщить нам в точности, что это за «исключение, какой-то там COM объект, бла, бла, бла». Потому что это сообщение пытается донести до вас (ну и до нас тоже), что же не так.
    – VladD
    17 мар 2016 в 21:39
  • Чтобы биржевая программа вызвала вашу функцию UpdateNotify(), она сначала должна создать экземпляр класса RtdUpdate, передав в него экземпляр RtdClient. Попробуйте сделать класс RtdUpdate статичным или синглтоном.
    – iRumba
    18 мар 2016 в 3:26
  • @iRumba бирже не надо ничего создавать - экземпляр класса RtdUpdate передается как параметр метода ServerStart в конструкторе. 18 мар 2016 в 8:12
  • Если передается экземпляр класса RtdUpdate, то должен передаваться и RtdClient в его составе.
    – iRumba
    18 мар 2016 в 9:00
  • @iRumba и что из этого следует? 18 мар 2016 в 9:54

1 ответ 1

1

Я бы использовал Publish/Subscribe архитектуру для сообщения между потоками и Inversion of Control для управления жизненным циклом потоков.

Publish/Subscribe это некая шина данных внутри приложения, через которую потоки общаются между собой.

В IoC контейнере в отдельном потоке создаём объект, который работает с COM объектом. Объект через делегат получает сообщение, на его базе создаёт своё внутренне сообщение которое отдаёт в шину данных.

Другие потоки (интерфейс(viewmodel) или другие обработчики) заранее подписаны на сообщения в этой шине данных, получают сообщения и используют по своему усмотрению.

Не сложные к освоению Publish/Subscribe и Ioc. Nuget:Microsoft.Practices.Prism.PubSubEvents
IoC контейнер NuGet:Unity 4.0.1

4
  • Да причем тут Publish/Subscribe? У автора проблема в другом. Вы приглядитесь как он свободный поток запрашивает... 12 июл 2016 в 16:16
  • Возможно офтоп, я не решаю конкретную задачу, но предлагаю автору изучить эти 2 техники и переписать код, чем вам не нравиться этот подход? 12 июл 2016 в 16:28
  • Автор уже нахватался идей, которые не смог понять - и потому у него сейчас программа зависает. А вы ему предлагаете еще одну непонятную идею. Неужели вы и правда думаете, что если он перепишет код используя pubsub, он выкинет свой ThreadManager? Нет, не выкинет - и будет у него две проблемы вместо одной. 12 июл 2016 в 16:31
  • Возможно автор не сможет возможно сможет, но я хотя бы попытался предложить подход, если до сих пор этот вопрос помечен "без ответа". 12 июл 2016 в 16:39

Ваш ответ

By clicking “Отправить ответ”, you agree to our terms of service and acknowledge you have read our privacy policy.

Всё ещё ищете ответ? Посмотрите другие вопросы с метками или задайте свой вопрос.