TIdTCPServer Contexts->LockList() 上的应用程序挂起

Question

我正在 C++ Builder XE2 中开发所谓的“feeder”应用程序，它使用 2 个内置的 Indy 组件 - TIdTCPClient 和 TIdTCPSever。 TIdTCPClient 用于从一个源接收数据，形成字符串消息，然后使用 TIdTCPSever 将此字符串消息发送到所有客户端应用程序。对于数据重新翻译，我使用下一个函数（idEventsServerSocket 是 TIdTCPSever 组件）：

void TfrmMainWindow::SendDataToAllClients(String msg) {

TList *ClientsList;
try
{
ClientsList = idEventsServerSocket->Contexts->LockList();


for (int i = 0; i < ClientsList->Count; i++) {
    TIdContext *Context = (TIdContext*)ClientsList->Items[i];


    bool connected = false;
    try {
        connected = Context->Connection->Connected();
    }
    catch (Exception&e) {

        continue;
    }

    if (!connected)
        continue;
    try {
        Context->Connection->IOHandler->WriteLn(msg);
        Context->Connection->IOHandler->WriteBufferFlush();
    }
    catch (Exception&e) {

    }

}
}
__finally
{
idEventsServerSocket->Contexts->UnlockList();
}


}

我还想注意这个函数包含在 EnterCriticalSection ... LeaveCriticalSection 代码段中，所以应该保证在函数没有执行之前不会有新的进入这个函数代码。对于 idEventsServerSocket，定义了 OnException 和 OnListenException 处理程序并包含空代码。

所以问题是：有时行

ClientsList = idEventsServerSocket->Contexts->LockList();

导致应用程序挂起。当它发生时没有一般规律，但看起来它在大多数时候发生，当函数 SendDataToAllClients 被非常频繁地调用（比如每 10 到 50 毫秒一次）。客户端连接数从 30 到 50 不等。 我需要知道的是，有什么办法可以避免这种僵局？我有任何检查（如 TryEnterCriticalSection）吗？ 另外我想承认Delphi: TThreadList sometimes lock program 的 Remy 解决方案没有帮助。

Answer 1

LockList() 需要位于 try 块之外。

Contexts 列表在内部使用了一个临界区，因此将此代码包装在您自己的临界区中是多余的。

LockList() 可以阻塞的唯一方法是，如果另一个线程已经获得了锁并且没有释放它，要么是因为它正忙于使用列表，要么它更可能崩溃并且没有释放锁。

请勿在此代码中调用 Connected() 或 WriteBufferFlush()。您没有使用写缓冲，从TIdTCPServer 事件之外调用Connected() 将导致连接的InpuBuffer 出现竞争条件，干扰管理该连接的服务器线程，这可能导致崩溃、死锁，损坏的入站数据等。只需自己调用Write()，如果套接字已断开连接，则让它抛出异常。

您所展示的是一种使用TIdTCPServer 实现 TCP 广播的不安全方式。您应该改为实现每个客户端线程安全的出站队列，并让OnExecute 事件处理实际写入：

#include <IdThreadSafe.hpp>

class TMyContext : public TIdServerContext
{
public:
    TIdThreadSafeStringList *Queue;
    bool HasMsgsInQueue;

    __fastcall TMyContext(TIdTCPConnection *AConnection, TIdYarn *AYarn, TIdContextThreadList *AList = NULL)
        : TIdServerContext(AConnection, AYarn, AList)
    {
        Queue = new TIdThreadSafeStringList;
        HasMsgsInQueue = false;
    }

    __fastcall TMyContext()
    {
        delete Queue;
    }
};

__fastcall TfrmMainWindow::TfrmMainWindow(TComponent *Owner)
    : TForm(Owner)
{
    // set this before activating the server
    idEventsServerSocket->ContextClass = __classid(TMyContext);
}

void TfrmMainWindow::SendDataToAllClients(const String &msg)
{
    TList *ClientsList = idEventsServerSocket->Contexts->LockList();
    try
    {
        for (int i = 0; i < ClientsList->Count; ++i)
        {
            TMyContext *Context = (TMyContext*) ClientsList->Items[i];
            try
            {
                TStringList *Queue = Context->Queue->Lock();
                try
                {
                    Queue->Add(msg);
                    Context->HasMsgsInQueue = true;
                }
                __finally
                {
                    Context->Queue->Unlock();
                }
            }
            catch (const Exception &)
            {
            }
        }
    }
    __finally
    {
        idEventsServerSocket->Contexts->UnlockList();
    }
}

void __fastcall TfrmMainWindow::idEventsServerSocketExecute(TIdContext *AContext)
{
    TMyContext *ctx = (TMyContext*) AContext;
    if (ctx->HasMsgsInQueue)
    {
        TStringList *Msgs = NULL;
        try
        {
            TStringList *Queue = ctx->Queue->Lock();
            try
            {
                Msgs = new TStringList;
                Msgs->Assign(Queue);
                Queue->Clear();
                ctx->HasMsgsInQueue = false;
            }
            __finally
            {
                ctx->Queue->Unlock();
            }

            AContext->Connection->IOHandler->Write(Msgs);
        }
        __finally
        {
            delete Msgs;
        }
    }

    if (AContext->Connection->IOHandler->InputBufferIsEmpty())
    {
        AContext->Connection->IOHandler->CheckForDataOnSource(100);
        AContext->Connection->IOHandler->CheckForDisconnect();

        if (AContext->Connection->IOHandler->InputBufferIsEmpty())
            return;
    }

    // handle inbound data as needed...
}