多线程编程1

   1:  #ifndef NORMALNODE

   2:  #define NORMALNODE

   3:  #include <iostream>

   4:  #include <sstream>

   5:  #include <queue>

   6:  #include <Windows.h>

   7:  //socket头文件

   8:  #include "winsock.h"

   9:  //socket库的lib

  10:  #pragma comment(lib,"ws2_32.lib")

  11:  using namespace std;

  12:   

  13:  typedef unsigned short int  uint;

  14:  typedef unsigned char uchar;

  15:  #define MAXSIZE 4000     // scan data模式  获得的最多点的个数

  16:   

  17:  const UINT16 Port1 = 8060; 

  18:  const UINT16 Port2 = 8080; 

  19:   

  20:  DWORD WINAPI Child0Func(LPVOID);

  21:  DWORD WINAPI Child1Func(LPVOID);

  22:   

  23:   char szbuffer[2][2000] = {0};//缓冲区用于存放字节流数据

  24:   

  25:   const int startoffset = 4;

  26:   const int PointLength = 6;

  27:   

  28:  CRITICAL_SECTION g_csThreadCode;

  29:   

  30:  typedef struct Point        //点转换为矩阵的x与y坐标。

  31:  {

  32:      uint x;

  33:      uint y;

  34:      uchar value;

  35:      uchar U;

  36:  } Point;

  37:   

  38:  typedef struct Matrix      //稀疏矩阵数据结构

  39:  {

  40:      int Num;

  41:      Point point[MAXSIZE];

  42:   

  43:  } Matrix;

  44:   

  45:  UINT16 count1 = 0;

  46:  Matrix matrix1;

  47:  Matrix matrix2;

  48:  #endif

   1:  // ThreadDemo6.cpp : 定义控制台应用程序的入口点。

   2:  //

   3:  #include "stdafx.h"

   4:  #include "Demo.h"

   5:  int _tmain(int argc, _TCHAR* argv[])

   6:  {

   7:      //初始化socket库

   8:      WSADATA wsa = {0}; //WinSockApi 取WSA+DATA组成套接字结构体

   9:      WSAStartup(MAKEWORD(2,2),&wsa);

  10:   

  11:      HANDLE hChild[4];

  12:      HANDLE hEvent[4];

  13:      DWORD threadId[4];

  14:      int obs1 = 0;

  15:      int obs2 = 0;

  16:      bool   bDone = false;

  17:   

  18:      DWORD dwStart = GetTickCount();

  19:      InitializeCriticalSection(&g_csThreadCode);

  20:      //CreateEvent创建一个事件的时候，最后一个字符串是该事件的名字，

  21:      //这样就可以在其余的地方通过这个名字来找到相应的事件了，等于是一个标识的作用 

  22:   

  23:      //第二个参数为true，所以为手动置位 。ResetEvent，使事件处于未触发状态

  24:      //一般情况下，当其处于触发状态，也就是SetEvent时，其他人可以更改

  25:      //第二个参数为false，表示自动置位，也就是不用ResetEvent。

  26:      //创建事件

  27:      hEvent[0] = CreateEventW(NULL,FALSE,FALSE,_T("ChildEvent0"));

  28:      hEvent[1] = CreateEventW(NULL,FALSE,FALSE,_T("ChildEvent1"));

  29:   

  30:      hChild[0] = CreateThread(NULL,0,Child0Func,0,0,&threadId[0]);//ID号与句柄

  31:      hChild[1] = CreateThread(NULL,0,Child1Func,0,0,&threadId[1]);

  32:   

  33:      /************************************************************************/

  34:      /*UDP部分                                                                */

  35:      /************************************************************************/

  36:      SOCKET sClient;

  37:      int iLen;  //服务器地址长度

  38:      int iSend; //接收数据的缓冲

  39:      struct sockaddr_in ser; //服务器端地址

  40:      //建立服务器端地址

  41:      ser.sin_family=AF_INET;

  42:      ser.sin_port=htons(8060);

  43:      ser.sin_addr.s_addr=inet_addr("127.0.0.1"); // 本机IP地址，测试用

  44:      //ser.sin_addr.s_addr = inet_addr("192.168.1.3");  //决策机IP地址

  45:   

  46:      //建立客户端数据报套接口

  47:      sClient=socket(AF_INET,SOCK_DGRAM,IPPROTO_UDP);

  48:   

  49:      if(sClient==INVALID_SOCKET)

  50:      {

  51:          printf("socket()Failed：%d\n",WSAGetLastError());

  52:          return  0;

  53:      } 

  54:      iLen=sizeof(ser);

  55:      /********************************以上是UDP发送部分程序*****************************/  

  56:   

  57:   

  58:      while(!bDone)

  59:      {    

  60:          //下面这个方法有两种状态，一个是一个个去响应事件，一个是总的去响应事件。

  61:          DWORD dwStatus = WaitForMultipleObjects(2,hEvent,TRUE,INFINITE);//infinite，不等待，setEvent可以使其返回为0

  62:          if ((dwStatus >= WAIT_OBJECT_0)&&(dwStatus <= WAIT_OBJECT_0 + 1 )   )

  63:          {

  64:              DWORD dwStart = GetTickCount();

  65:              EnterCriticalSection(&g_csThreadCode);//进入关键段  临界区

  66:              //数据处理 

  67:              UINT8 str1[2000] = {0};

  68:              UINT8 str2[2000] = {0};

  69:              //开辟两个无符号类型，这里是加了锁机制处理,string 默认并不是无符号类型

  70:              for (int i = 0; i < 2000; ++i)

  71:              {

  72:                  str1[i] = szbuffer[0][i];  

  73:                  str2[i] = szbuffer[1][i];

  74:              }

  75:              matrix1.Num = str1[3]*16*16*16 + str1[2]*16*16 + str1[1]*16 + str1[0];  

  76:              matrix2.Num = str2[3]*16*16*16 + str2[2]*16*16 + str2[1]*16 + str2[0];

  77:              for (int i = 0; i < matrix1.Num; ++i)

  78:              {

  79:                  matrix1.point[obs1].x     = str1[startoffset + 1 + i*PointLength]*16 + str1[startoffset + 0 + i*PointLength];

  80:                  matrix1.point[obs1].y     = str1[startoffset + 3 + i*PointLength]*16 + str1[startoffset + 2 + i*PointLength];

  81:                  matrix1.point[obs1].value = str1[startoffset + 4 + i*PointLength];

  82:                  matrix1.point[obs1].U     = str1[startoffset + 5 + i*PointLength];

  83:                  obs1++;  //注意清零

  84:              }

  85:              for (int i = 0; i < matrix2.Num; ++i)

  86:              {

  87:                  matrix2.point[obs2].x     = str1[startoffset + 1 + i*PointLength]*16 + str1[startoffset + 0 + i*PointLength];

  88:                  matrix2.point[obs2].y     = str1[startoffset + 3 + i*PointLength]*16 + str1[startoffset + 2 + i*PointLength];

  89:                  matrix2.point[obs2].value = str1[startoffset + 4 + i*PointLength];

  90:                  matrix2.point[obs2].U     = str1[startoffset + 5 + i*PointLength];

  91:                  obs2++;  //注意清零

  92:              }

  93:              obs1 = 0;

  94:              obs2 = 0;

  95:              Point poi;

  96:              //数据求并集然后发送

  97:              for (int i = 0; i < matrix1.Num; ++i)

  98:              {

  99:                  poi = matrix1.point[i];       //四线雷达数据集

 100:                  for (int j = 0; j < matrix2.Num; ++j)

 101:                  {

 102:                      if ((poi.x == matrix2.point[j].x) && (poi.y == matrix2.point[j].y))

 103:                      {

 104:                          matrix2.point[j] = matrix2.point[j+1];//大的替换小的

 105:                          matrix2.Num--;

 106:                          break;

 107:                      }

 108:                  }

 109:              }

 110:   

 111:              for (int i = 0; i < matrix2.Num; ++i)

 112:              {

 113:                  matrix1.point[matrix1.Num + i] = matrix2.point[i];

 114:              }

 115:              matrix1.Num = matrix1.Num + matrix2.Num;

 116:   

 117:              uint len = matrix1.Num*sizeof(Point) + 4; 

 118:              char buffer[10000];

 119:              memcpy(buffer,(char*)&matrix1,len);

 120:              iSend=sendto(sClient,buffer,len-1,0,(struct sockaddr*)&ser,iLen);

 121:              cout << "*************Total time:" << GetTickCount() - dwStart << endl;

 122:              LeaveCriticalSection(&g_csThreadCode);//离开关键段

 123:          }

 124:      }

 125:   

 126:   

 127:      for (int j = 0; j < 4; ++j)

 128:      {

 129:          CloseHandle(hEvent[j]);

 130:          CloseHandle(hChild[j]);

 131:      }

 132:      DeleteCriticalSection(&g_csThreadCode);

 133:      cout << "*************Total time:" << GetTickCount() - dwStart << endl;

 134:      return 0;

 135:  }

 136:   

 137:   

 138:  //子线程可以将主线程创建的Event激活

 139:  DWORD WINAPI Child0Func(LPVOID p) 

 140:  {

 141:      HANDLE hEvent;

 142:      hEvent = OpenEventW(EVENT_ALL_ACCESS,FALSE,_T("ChildEvent0"));

 143:      SOCKET socksvr = socket(AF_INET,SOCK_DGRAM,IPPROTO_UDP);

 144:      if (INVALID_SOCKET == socksvr)

 145:      {

 146:          return 0;

 147:      }

 148:      struct sockaddr_in svraddr = {0};

 149:      svraddr.sin_family = AF_INET;

 150:      svraddr.sin_port = htons(5070);

 151:      svraddr.sin_addr.S_un.S_addr = htonl(INADDR_ANY);

 152:      if ( bind(socksvr,(struct sockaddr*)&svraddr,sizeof(svraddr)) == SOCKET_ERROR)//地址与套接字绑定

 153:      {

 154:          cout << "套接字绑定错误" << endl;

 155:          return 0;

 156:      }

 157:      struct sockaddr_in clientaddr = {0};

 158:      int nLen = sizeof(clientaddr);

 159:      while (true)

 160:      {

 161:          recvfrom(socksvr,(char*)szbuffer[0],2000,0,(struct sockaddr*)&clientaddr,&nLen);//构造ip地址

 162:          // cout << "flag1:  "<<count1++ <<endl;

 163:          SetEvent(hEvent); //将事件置为有信号状态，WaitForObject返回为WAIT_OBJECT_0

 164:      }

 165:  }

 166:   

 167:  //子线程可以将主线程创建的Event激活

 168:  DWORD WINAPI Child1Func(LPVOID p) 

 169:  {

 170:      HANDLE hEvent;

 171:      hEvent = OpenEventW(EVENT_ALL_ACCESS,FALSE,_T("ChildEvent1"));

 172:      SOCKET socksvr = socket(AF_INET,SOCK_DGRAM,IPPROTO_UDP);

 173:      if (INVALID_SOCKET == socksvr)

 174:      {

 175:          return 0;

 176:      }

 177:      struct sockaddr_in svraddr = {0};

 178:      svraddr.sin_family = AF_INET;

 179:      svraddr.sin_port = htons(5080);

 180:      svraddr.sin_addr.S_un.S_addr = htonl(INADDR_ANY);

 181:      if ( bind(socksvr,(struct sockaddr*)&svraddr,sizeof(svraddr)) == SOCKET_ERROR)//地址与套接字绑定

 182:      {

 183:          cout << "套接字绑定错误" << endl;

 184:          return 0;

 185:      }

 186:      struct sockaddr_in clientaddr = {0};

 187:      int nLen = sizeof(clientaddr);

 188:      while (true)

 189:      {

 190:          recvfrom(socksvr,(char*)szbuffer[1],2000,0,(struct sockaddr*)&clientaddr,&nLen);//构造ip地址

 191:          // cout << "flag2:  "<<count1++ <<endl;

 192:          SetEvent(hEvent); //将事件置为有信号状态，WaitForObject返回为WAIT_OBJECT_0

 193:      }

 194:  }