线程-事件机制

向右看齐 2022-09-25 02:19 124阅读 0赞

一对一 模式：这里主要是对 createevent() 参数的设置有所了解。

#include<stdlib.h>
    #include<stdio.h>
    #include<windows.h>
    //互斥：解决线程冲突
    //事件：解决线程通信
    //临界区：解决线程冲突
    //定时器：解决同步线程
    
    HANDLE event[5] = { 0 };
    HANDLE thread[5] = { 5 };
    
    
    DWORD WINAPI aa(void *p)
    {
    	int i = 0;
    	printf("AA说了 %d 句\n", i);
    	Sleep(1000);
    	SetEvent(event[0]);
    	while (++i)
    	{	
    		WaitForSingleObject(event[1], INFINITE);
    		printf("AA说了 %d 句\n", i);
    		Sleep(1000);
    		ResetEvent(event[1]);		//信号复原
    		SetEvent(event[0]);
    	}
    }
    
    DWORD WINAPI bb(void *p)
    {
    	int i = 0;
    	while (++i)
    	{
    		WaitForSingleObject(event[0], INFINITE);
    		printf("BB说了 %d 句\n", i);
    		Sleep(2000);
    		ResetEvent(event[0]);		//信号复原
    		SetEvent(event[1]);
    		
    	}
    }
    void main()
    {
    	//参数1：安全属性
    	//参数2： 复位方式：指定将事件对象创建成手动复原还是自动复原。如果是TRUE，那么必须用ResetEvent函数来手工将事件的状态复原到无信号状态。如果设置为FALSE，当一个等待线程被释放以后，系统将会自动将事件状态复原为无信号状态。
    	//参数3：初始状态
    	//参数4：对象名称
    	event[0] = CreateEvent(NULL, FALSE, FALSE, NULL);
    	event[1] = CreateEvent(NULL, FALSE, FALSE, NULL);
    
    	thread[0] =	CreateThread(NULL, 0, aa, NULL, 0, NULL);
    	thread[1] = CreateThread(NULL, 0, bb, NULL, 0, NULL);
    
    	WaitForMultipleObjects(2, thread, TRUE, INFINITE);
    
    	system("pause");
    }

中介者模式：

中介者模式如下图所示![Center][]

#define _CRT_SECURE_NO_WARNINGS
    #include<stdlib.h>
    #include<stdio.h>
    #include<windows.h>
    //互斥：解决线程冲突
    //事件：解决线程通信
    //临界区：解决线程冲突
    //定时器：解决同步线程
    
    HANDLE event[5] = { 0 };
    HANDLE thread[5] = { 5 };
    char str[1024] = { 0 };
    
    
    DWORD WINAPI aa(void *p)
    {
    	int i = 1;
    	memset(str, '0', 1024);
    	sprintf(str,"AA说了 %d 句\n", i);	
    	
    	SetEvent(event[1]);
    	while (++i)
    	{
    		WaitForSingleObject(event[0], INFINITE);
    		memset(str, '0', 1024);
    		sprintf(str, "AA说了 %d 句\n", i);
    		
    		Sleep(1000);
    		//ResetEvent(event[0]);		//信号复原
    		SetEvent(event[1]);
    	}
    }
    
    
    DWORD WINAPI bb(void *p)
    {
    
    	int i = 0;
    	while (++i)
    	{
    		WaitForSingleObject(event[2], INFINITE);
    		memset(str, '0', 1024);
    		sprintf(str,"BB说了 %d 句\n", i);			
    		Sleep(1000);
    		
    		//ResetEvent(event[2]);		//信号复原
    		SetEvent(event[3]);
    
    	}
    }
    
    DWORD WINAPI zj(void *p)
    {
    	while (1)
    	{
    		WaitForSingleObject(event[1], INFINITE);
    		printf("%s", str);		
    		SetEvent(event[2]);
    		WaitForSingleObject(event[3], INFINITE);
    		printf("%s", str);		
    		SetEvent(event[0]);
    	}
    
    	//int i = 0;
    	//int k = 0;	//切换
    	//while (++i)
    	//{
    	//	if (k == 0)
    	//	{
    	//		WaitForSingleObject(event[1], INFINITE);
    	//		printf("中介者说模式 %s",str);
    	//		Sleep(1000);
    	//		SetEvent(event[2]);
    	//		k = 1;
    	//	}
    	//	else
    	//	{
    	//		WaitForSingleObject(event[3], INFINITE);
    	//		printf("中介者说模式 %s", str);
    	//		Sleep(1000);
    	//		SetEvent(event[0]);
    	//		k = 0;
    	//	}
    	//}
    
    }
    
    
    void main()
    {
    	//参数1：安全属性
    	//参数2： 复位方式：指定将事件对象创建成手动复原还是自动复原。如果是TRUE，那么必须用ResetEvent函数来手工将事件的状态复原到无信号状态。如果设置为FALSE，当一个等待线程被释放以后，系统将会自动将事件状态复原为无信号状态。
    	//参数3：初始状态
    	//参数4：对象名称
    	event[0] = CreateEvent(NULL, FALSE, FALSE, NULL);
    	event[1] = CreateEvent(NULL, FALSE, FALSE, NULL);
    	event[2] = CreateEvent(NULL, FALSE, FALSE, NULL);
    	event[3] = CreateEvent(NULL, FALSE, FALSE, NULL);
    
    	thread[0] = CreateThread(NULL, 0, aa, NULL, 0, NULL);
    	thread[1] = CreateThread(NULL, 0, bb, NULL, 0, NULL);
    	thread[2] = CreateThread(NULL, 0, zj, NULL, 0, NULL);
    
    	WaitForMultipleObjects(3, thread, TRUE, INFINITE);
    
    	system("pause");
    }

广播模式：即一对多，这里主要注意对事件机制参数的设置。

#define _CRT_SECURE_NO_WARNINGS
    #include<stdlib.h>
    #include<stdio.h>
    #include<windows.h>
    //互斥：解决线程冲突
    //事件：解决线程通信
    //临界区：解决线程冲突
    //定时器：解决同步线程
    
    HANDLE event[5] = { 0 };
    HANDLE thread[10] = { 0 };
    char str[10] = { 'A', 'B', 'C', 'D', 'E', 'F', 'G', 'H', 'I', 'J' };
    
    DWORD WINAPI threadDemo(void *p)
    {
    	char *pstr = p;
    	printf("线程 %c 正在被执行......\n", *pstr);
    	if (*pstr == 'A')
    	{
    		MessageBoxA(NULL, "等待中......", "waitting", 0);
    		//SetEvent(event[0]);
    		
    	}
    
    		WaitForSingleObject(event[0], INFINITE);
    		printf("开始执行中 %c....\n", *pstr);
    		Sleep(1000);
    		//如果下面在使用这个信号，这作就应该使用 ResetEevent() 来复原这个信号
    		//ResetEvent(event[0]);
    
    		//如果 event[0] = CreateEvent(NULL, FALSE, FALSE, NULL); 
    		//第二个参数设置为 FALSE 时，这时需要广播信息，就需要使用 SetEVent(event[0]);来重新设置信息
    		//SetEvent(event[0]); 
    		
    
    	return 1;
    }
    
    void main()
    {
    	//参数1：安全属性
    	
    	//参数2： 复位方式：指定将事件对象创建成手动复原还是自动复原。
    	//如果是TRUE，那么必须用ResetEvent函数来手工将事件的状态复原到无信号状态。
    	//如果设置为FALSE，当一个等待线程被释放以后，系统将会自动将事件状态复原为无信号状态。
    	//一定要注意 参数2 的设定
    
    	//参数3：初始状态
    	//参数4：对象名称
    	event[0] = CreateEvent(NULL, TRUE, FALSE, NULL);
    
    	for (int i = 0; i < 10; i++)
    	{
    		thread[0] = CreateThread(NULL, 0, threadDemo, &str[i], 0, NULL);
    	}
    
    	WaitForMultipleObjects(10, thread, TRUE, INFINITE);
    
    	system("pause");
    }

[Center]: /images/20220719/46c87520eae7460c820ae9eb824eed6d.png