Windows Kernel

Development Platform:

Visual C++

worker.h：Code Content

							// worker.h : Declaration of the CWorkerThread
#ifndef __WORKER_H_
#define __WORKER_H_
#include "iface.h"          // for IWorkerEvent
// CWorkerThread
class CWorkerThread : public IARPWorker
{
public:
    CWorkerThread();
    virtual ~CWorkerThread();
    
    // *** IUnknown ***
    virtual STDMETHODIMP_(ULONG) AddRef   (void);
    virtual STDMETHODIMP_(ULONG) Release  (void);
    virtual STDMETHODIMP QueryInterface   (REFIID riid, LPVOID * ppvObj);
    // *** IARPWorker ***
    virtual STDMETHODIMP KillWT (void);
    STDMETHOD(StartWT)          (int iPriority);
    STDMETHOD(SetListenerWT)    (IWorkerEvent * pwe);
    
    BOOL    IsKilled() { return _fKillWorker; };
    BOOL    PostWorkerMessage(UINT uMsg, WPARAM wParam, LPARAM lParam);
    
    virtual DWORD   _ThreadStartProc();
protected:
    DWORD   _dwThreadId;
private:
    void    _LockWorker(void);
    void    _UnlockWorker(void);
    LONG    _cRef;
    
    CRITICAL_SECTION _csWorker;
    DEBUG_CODE( LONG _cRefLockWorker; )
    
    LONG    _cItems;
    IWorkerEvent * _pwe;
    
    BITBOOL _fKillWorker: 1;
    HANDLE  _hthreadWorker;
    HWND    _hwndWorker;
    LRESULT _WorkerWndProc(HWND hwnd, UINT uMsg, WPARAM wParam, LPARAM lParam);
    
    static DWORD CALLBACK _ThreadStartProcWrapper(LPVOID lpParam);
    static LRESULT CALLBACK _WorkerWndProcWrapper(HWND hwnd, UINT uMsg, WPARAM wParam, LPARAM lParam);
};
// Window messages from worker thread that cause actions on the main thread
#define WORKERWIN_FIRE_ROW_READY          (WM_USER + 0x0101)  // wParam is row #
#define WORKERWIN_FIRE_FINISHED           (WM_USER + 0X0102)
#define WORKERWIN_FIRE_DATASETCHANGED     (WM_USER + 0X0103)
#endif //__WORKER_H_

						