sparkthreadpool

c++98/03 windows threadpool

新增特性：

1.线程池安全回调解决方案

1.1 SPARK_INSTANCE_DESTROY_TASKS(this);

    类析构时调用，安全结束运行的线程任务

1.2 智能指针
    
    class CTest : public SparkEnableSharedFromThis<CTest>
    {
    public:
        virtual ~CTest() {}
        void TestDoAsync()
        {
            SparkThreadPool::Instance().Execute(GetSelfSharedPtr(), &CTest::DoAsync1);
        }
        void DoAsync1()
        {
            ::Sleep(12000);
        }
    
    private:
        SparkSharedPtr<CTest> GetSelfSharedPtr()
        {
            return SharedFromThis();
        }
    };
    
    SparkSharedPtr<CTest> test(new CTest);
    test->TestDoAsync();

2.添加UI定时器的使用

SparkWndTimer::Schedule(this, &T::DoDelay, NULL, 2000, 10);

UI定时器运行在主线程，方便做延时任务，支持设置执行多次

窗口销毁时调用

SparkWndTimer::DestroyThisTimerTask(this);

+++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++

一行代码让函数运行在工作线程中/主线程中

SPARK_INSTANCE_SWTICH_TO_WORKTHREAD

SPARK_INSTANCE_POST_MSG_EX

还有更多简易的异步任务宏

QQ:396628781

有问题可以联系我

void CMainDlg::PrintText(LPCTSTR format, ...)

{

if (format)

{
    va_list args;
    va_start(args, format);

    CString strText;
    strText.FormatV(format, args);

    va_end(args);

    SPARK_INSTANCE_POST_MSG_EX(CMainDlg, DoInMainThread, strText);
}

}

void CMainDlg::DoInMainThread(CString strText)

{

strText.AppendFormat(L"\r\n输出日志运行线程ID：%d\r\n\r\n", ::GetCurrentThreadId());
CString strLog;
GetDlgItemText(IDC_STATIC_TEXT, strLog);

strLog.Append(strText);
SetDlgItemText(IDC_STATIC_TEXT, strLog);

HWND hEditWnd = GetDlgItem(IDC_STATIC_TEXT);
::SendMessage(hEditWnd, EM_SETSEL, -1, -1);

}

void CMainDlg::DoInWorkThread(int a, int b)

{

SPARK_INSTANCE_SWTICH_TO_WORKTHREAD(CMainDlg, DoInWorkThread, a, b);

PrintText(L"工作线程ID：%d,开始工作,休息2秒", ::GetCurrentThreadId());

::Sleep(2000);
int n = a + b;

PrintText(L"工作线程ID：%d,完成工作,结果：%d", ::GetCurrentThreadId(), n);

}