多线程—热水器加热全过程.doc

模拟热水器加热的小程序，程序逻辑其实很简单，唯一不同的是创建了四个线程来模拟热水器的侦测水位、侦测水温、上水和加热四个功能，同时用四个内核对象进行线程间的同步。具体代码如下 #ifndef UNICODE #define UNICODE#endif#ifdef UNICODE #ifndef _UNICODE #define _UNICODE #endif#endif#include #include #include #include using namespace std;typedef unsigned (_stdcall *PTHREAD_ADDR)(void*);#define chBEGINTHREADEX(psa, cbStackSize, pfnStartAddr, pvParam, dwCreateFlags, pdwThreadId) (HANDLE)_beginthreadex( (void*) (psa), (unsigned) (cbStackSize), (PTHREAD_ADDR) (pfnStartAddr), (void*) (pvParam), (unsigned) (dwCreateFlags), (unsigned*) (pdwThreadId)HANDLE h_detect_temp;/侦测温度HANDLE h_detect_pos;/侦测水位HANDLE h_continue_fill;/继续上水HANDLE h_continue_heat;/继续加热BOOL is_stop = FALSE;/停止加热BOOL is_full = FALSE;/停止上水int water_pos = 0;/初始水位int water_temp = 0;/初始水温void ShowMessage(PTSTR szFormat, .) TCHAR szText260; va_list arglist; va_start(arglist, szFormat); _vstprintf_s(szText, _countof(szText), szFormat, arglist); va_end(arglist); wcout= 100) is_full = TRUE; ShowMessage(L现在水位达到%d%s！n, water_pos, L%); SetEvent(h_continue_fill); break; if(water_pos % 25 = 0) ShowMessage(L现在的水位达到%d%s。n, water_pos, L%); SetEvent(h_continue_fill);/设置继续上水事件的状态为有信号 return 0;/上水DWORD WINAPI FillTank(PVOID pvParam) while(true) SignalObjectAndWait(h_detect_pos, h_continue_fill, INFINITE, TRUE);/设置检测水位事件信号，等待继续上水事件信号 if(is_full) break; water_pos+; return 0;/侦测水温DWORD WINAPI DetectTemp(PVOID pvParam) int limit_temp = (int)pvParam; while(true) WaitForSingleObject(h_detect_temp, INFINITE); if(water_temp = limit_temp) is_stop = TRUE; ShowMessage(L水温已达到设定温度%d度！n, limit_temp); SetEvent(h_continue_heat); break; if(water_temp % 5 = 0) ShowMessage(L现在的水温是摄氏%d度。n, water_temp); SetEvent(h_continue_heat); return 0;/加热DWORD WINAPI HeatWater(PVOID pvParam) while(true) SignalObjectAndWait(h_detect_temp, h_continue_heat, INFINITE, TRUE); if(is_stop) break; if(water_pos = 25)/水位低于25%时不加热 water_temp+; return 0;int _tmain(int argc, TCHAR *argv) wcout.imbue(locale(chs); /创建四个自动重置事件对象，分别为检测水位、继续上水、检测水温、继续加热 h_detect_pos = CreateEvent(NULL, FALSE, TRUE, NULL);/设置为有信号状态，以便开始就检测水位 h_continue_fill = CreateEvent(NULL, FALSE, FALSE, NULL); h_detect_temp = CreateEvent(NULL, FALSE, TRUE, NULL);/设置为有信号状态，以便开始就检测水温 h_continue_heat = CreateEvent(NULL, FALSE, FALSE, NULL); HANDLE h_thread4; /创建四个线程，分别是上水、检测水位、加热、检测水温 h_thread0 = chBEGINTHREADEX(NULL, 0, FillTank, NULL, 0, NULL); h_thread1 = chBEGINTHREADEX(NULL, 0, DetectPos, NULL, 0, NULL); h_thread2 = chBEGINTHREADEX(NULL, 0, HeatWater, NULL, 0, NULL); h_thread3 = chBEGINTHREADEX(NULL, 0, DetectTemp, 50, 0, NULL); /等待四个线程执行完毕，释放内核对象 DWORD dw = WaitForMultipleObjects(4, h_thread, TRUE, INFINITE); for(int i = 0; i 4; i+) CloseHandle(h_threadi); CloseHandle(h_detect_pos); CloseHandle(h_continue_fill); CloseHandle(h_detect_temp); CloseHandle(h_con