Unity LLApi MessagesConsumer.cs

LLApi MessagesConsumer.cs

 public void Start()
    {
        Disconnect = false;

        //@todo tune params!
        var gConfig = new GlobalConfig
        {
            ThreadPoolSize = threadPoolSize,
            MaxPacketSize = maxPacketSize
        };

        NetworkTransport.Init(gConfig);
        SocketId = NetworkTransport.AddHost(Topology, Port);
        ProcessWorkers = new Thread[workerProcessCount];

        // Create and start a separate thread for each worker
        for (int i = 0; i < workerProcessCount; i++)
        {
            ProcessWorkers[i] = new Thread(MessagesConsumer);
            ProcessWorkers[i].Name = "LLApi Process Thread " + i;
            ProcessWorkers[i].Start();
        }

        isConnected = true;
    }
    
    private void MessagesConsumer()
    {
        try
        {
            while (true)
            {
                InputMessage message;
                lock (lockPocessObject)
                {
                    while (InputMessagesQueue.Count == 0)
                    {
                        Monitor.Wait(lockPocessObject);
                    }
                    message = InputMessagesQueue.Dequeue();
                }

                //@todo is it for stopping trheads?
                if (message == null) return;
                lock (lockHandlers)
                {
                    SubjectDelegate handlerDelegate;
                    if(SubjectHandlers.TryGetValue(message.MsgSubject, out handlerDelegate))
                    {
                        handlerDelegate.Invoke(message);
                    }
                }
            }
        }
        catch (Exception e)
        {
            Debug.LogException(e);
        }

    }