🚀 go-pugleaf

Hi,

Off to work soon, so just in case this helps, an example help thread:

void
ClientTask::SendAMessage( int ID,
                                            char * Message )
{
    if (MyMbx)
    {
        // class/structure to add params to input Q

        AMessage * sl = new AMessage( int ID, char * Message );

        // My own thread safe mainbox, add item to end of list.  It has 
critical section around add and remove methods,
        // and signals the thread using its TEvent when adding

        // You could use TThreadList (LockList, UnlockList, Add, Remove 
etc), and TEvent directly: event->SetEvent();

        MyMbx->AddMailMsg(sl);
    }
}

ClientTask::Execute()
{
    while (!Terminated))
    {
        // get msg off queue, if one exists (thread safe), or TThreadList
        msg = (AMessage *) MyMbx->RemoveMailMsg();

        // if no msg, wait for wakeup
        if (!msg)
        {
             // wait for multiple objects API using TEvent handle, or 
timeout
            signalled = WaitForWakeUp(1000);

            // get message off fron of Q, as before this is my Q system, but 
you could use TThreadList
            msg = (AMessage *) MyMbx->RemoveMailMsg();
        }

        // if msg on queue, send
        if (msg)
        {
            SendToServer(msg);
            delete msg;
        }

    } // do forever (or nearly)
}

> That's the effect I'm trying to achieve, but I'm having trouble figuring 
> out a thread-safe method of doing that.