C语言Windows下多线程编程入门

小咪咪 2022-04-15 20:55 390阅读 0赞

#include <stdio.h>
    #include <process.h>
    #include <windows.h>
    
    #include "base.h"
    
    #define MAX_RETRY_COUNT 3
    
    HANDLE workThread;
    HANDLE prtThread;
    
    void *workThrEntry(void *param);
    void *prtThrEntry(void *param);
    
    unsigned int workThrId;
    unsigned int prtThrId;
    
    BOOL isWorkThrAlive = BOOL_FALSE;//工作线程是否存活
    HANDLE workThrAliveSem;//工作线程是否存活的信号量
    
    RESULT startPrtThread();
    RESULT startWorkThread();
    
    void setWorkThrAlive(BOOL b);
    BOOL getWorkThrAlive();
    
    void main(void)
    {	
    	workThrAliveSem = CreateSemaphore(NULL,1,1,(LPCWSTR)"Sem for work thread alive parameter!");
    
    	if (SUCCESS == startPrtThread())
    	{
    		startWorkThread();
    	}
    	
    	WaitForSingleObject(prtThread,INFINITE);
    
    	CloseHandle(prtThread);
    	CloseHandle(workThread);
    	CloseHandle(workThrAliveSem);
    }
    
    RESULT startWorkThread()
    {
    	workThread = (HANDLE)_beginthreadex(NULL,0,(unsigned int (_stdcall *)(void *))workThrEntry,0,0,&workThrId);
    	if (NULL == workThread)
    	{
    		printf("ERROR: Create work thread failed!\n");
    		setWorkThrAlive(BOOL_FALSE);
    		return FAILURE;
    	}
    	else
    	{
    		printf("INFO: Create work thread succeed!\n");
    		return SUCCESS;
    	}
    }
    
    RESULT startPrtThread()
    {
    	prtThread = (HANDLE)_beginthreadex(NULL,0,(unsigned int(_stdcall *)(void *))prtThrEntry,0,0,&prtThrId);
    	if (NULL == prtThread)
    	{
    		printf("ERROR: Create print thread failed!\n");
    		return FAILURE;
    	}
    	else
    	{
    		printf("Info: Create print thread succeed!\n");
    		return SUCCESS;
    	}
    }
    
    void *workThrEntry(void *param)
    {
    	setWorkThrAlive(BOOL_TRUE);
    
    	while (1)
    	{
    		
    	}
    
    	setWorkThrAlive(BOOL_FALSE);
    
    	return NULL;
    }
    
    /**
     * 每秒针检测工作线程是否退出，没退出则打印相关信息。
     **/
    void *prtThrEntry(void *param)
    {
    	int retryCount = 0;
    	BOOL isFirstPrint = BOOL_TRUE;
    
    	while (1)
    	{
    		if (BOOL_FALSE == getWorkThrAlive())
    		{
    			if (MAX_RETRY_COUNT == retryCount)
    			{
    				printf("INFO: The work thread has extied!\n");
    				break;
    			}
    			else
    			{
    				Sleep(500);
    				retryCount++;
    				continue;
    			}
    		}
    
    		if (BOOL_TRUE == isFirstPrint)
    		{
    			printf("Running...");
    			isFirstPrint = BOOL_FALSE;
    		}
    		else
    		{
    			printf(".");
    		}
    		Sleep(500);
    	}
    
    	return NULL;
    }
    
    void setWorkThrAlive(BOOL b)
    {
    	WaitForSingleObject(workThrAliveSem,INFINITE);
    	isWorkThrAlive = b;
    	ReleaseSemaphore(workThrAliveSem,1,NULL);
    }
    
    BOOL getWorkThrAlive()
    {
    	BOOL b;
    	WaitForSingleObject(workThrAliveSem,INFINITE);
    	b = isWorkThrAlive;
    	ReleaseSemaphore(workThrAliveSem,1,NULL);
    	return b;
    }

执行结果如下：

![a2445184-b5f4-327d-8055-2d162409bd4a.png][]

[a2445184-b5f4-327d-8055-2d162409bd4a.png]: /images/20220416/1d105a74428743808274fba378188847.png