C++ Worker threads with Builder (Borland Libraries)

Question

我有一个应用程序，基本上有一个 GUI 和一个负责运行我的主程序和创建对象的功能。

目前我的 GUI 会崩溃，因为有太多的后台工作正在进行，当后台工作完成后，它会再次恢复活力。

我需要创建一个工作线程(我们不需要接口(interface)线程，因为我的 GUI 只显示正在发生的事情的进度。)，工作线程将运行我的函数，另一个工作线程将运行我的 GUI。

我正在努力寻找这方面的任何信息。谷歌似乎没有帮助，任何人都可以指出一些有用的信息吗？目前我有这样的事情:

void __fastcall TfrmRunning::FormCreate(TObject *Sender)
{
   //Does most of my background stuff when this form is created
}

Answer 1

Threadz 很容易与 C++ Builder 结合使用，尤其是。如果您不需要任何 GUI 通信。我不得不就 GUI 通信的问题询问有关 SO 的建议 - 需要一个宏来处理消息，我提供了错误的表单类 - 我得到了堆栈溢出:)

'classes'里有一个TThread类，类似于Delphi。覆盖“执行”以执行您的线程代码，例如:

class TpoolThread : public TThread{
    CBthreadPool *FmyPool;
protected:
     virtual void __fastcall Execute(void);
public:
    TpoolThread(CBthreadPool *myPool):TThread(true){
        FmyPool=myPool;
        Resume();
    };
};

如果您没有 TThread 类(我有 C++ Builder 2009 - 不确定是否更早)，您可以按照@inkooboo 的建议回退到 API 调用。 WINAPI CreateThread() 只会调用直接的 C 风格函数或静态方法，因此您通常需要显式传递一个实例(通常为“this”)作为 CreateThread 参数，以便从线程代码中调用实例方法。使用 CreateThread API 的 ThreadPool 示例(尽管我确信如果您有 STL，您也会有 TThread):

#ifndef cthreadpoolH
#define cthreadpoolH

#include <Classes.hpp>
#include <deque.h>

class ThreadPool;

class PoolTask {
friend class ThreadPool;
    TNotifyEvent FonComplete;
protected:
    ThreadPool *myPool;
    int param;
public:
    PoolTask(int inParam, TNotifyEvent OnDone):param(inParam),FonComplete(OnDone){};
    virtual void run()=0;
};

template <typename T> class PCSqueue{
    CRITICAL_SECTION access;
    deque<T> *objectQueue;
    HANDLE queueSema;
public:
    PCSqueue(){
        objectQueue=new deque<T>;
        InitializeCriticalSection(&access);
        queueSema=CreateSemaphore(NULL,0,MAXINT,NULL);
    };
    void push(T ref){
        EnterCriticalSection(&access);
        objectQueue->push_front(ref);
        LeaveCriticalSection(&access);
        ReleaseSemaphore(queueSema,1,NULL);
    };
    bool pop(T *ref,DWORD timeout){
        if (WAIT_OBJECT_0==WaitForSingleObject(queueSema,timeout)) {
            EnterCriticalSection(&access);
            *ref=objectQueue->back();
            objectQueue->pop_back();
            LeaveCriticalSection(&access);
            return(true);
        }
        else
            return(false);
    };
};

class ThreadPool {
    int FthreadCount;
    PCSqueue<PoolTask*> queue;
public:
    ThreadPool(int initThreads){
        for(FthreadCount=0;FthreadCount!=initThreads;FthreadCount++){
            CreateThread(NULL,0,staticThreadRun,this,0,0);
        };
    }
    void setThreadCount(int newCount){
        while(FthreadCount<newCount){
            CreateThread(NULL,0,staticThreadRun,this,0,0);
            FthreadCount++;
        };
        while(FthreadCount>newCount){
            queue.push((PoolTask*)NULL);
            FthreadCount--;
        };
    }
    static DWORD _stdcall staticThreadRun(void *param){
        ThreadPool *myPool=(ThreadPool*)param;
        PoolTask *thisTask;
        SetThreadPriority(GetCurrentThread(),THREAD_PRIORITY_BELOW_NORMAL);
        while (myPool->queue.pop(&thisTask,INFINITE)){
            if(thisTask==NULL){return(0);};
            thisTask->run();
            if (thisTask->FonComplete!=NULL) {
                thisTask->FonComplete((TObject*)thisTask);
            }
        }
    }
    void submit(PoolTask *aTask){
        aTask->myPool=this;
        queue.push(aTask);
    };
};

#endif