SOCKET sock;
typedef struct {
  int state;
  char buf[1000];
} msg_t;
msg_t msg[1000]; // буфера для приема сообщений

void read_thread()
{
 while(true) {
   size = recvfrom(sock, msg[i].buf, 1000, ...); // приняли
   msg[i].state = NEED_PARSE; // пометили на обработку
   i = (i + 1) % 1000; // берем следующий буфер
 }
}

void parse_thread()
{
 while(true) {
  for(int i = 0; i < 1000) {
     if(msg[i].state == NEED_PARSE) {
       ... обработка
       sendto(sock, ...); // отправка
       msg[i].state = FREE;
     }
  }
 }
}

int main()
{
 sock = socket(AF_INET, SOCK_DGRAM, IPPROTO_UDP);
 bind(sock, ...);
 _beginthread(parse_thread, ....);
 read_thread();
}

int main()
{
 SOCKET sock;
 sock = socket(AF_INET, SOCK_DGRAM, IPPROTO_UDP);
 bind(sock, ...);
 while(true) {
  char buf[1000];
   size = recvfrom(sock, buf, 1000, ...); // принял
   ... обработка
   sendto(sock, ...); // отправил
 }
}

SOCKET sock;
typedef struct {
  int state;
  char buf[1000];
} msg_t;

int main()
{
 sock = socket(AF_INET, SOCK_DGRAM, IPPROTO_UDP);
 bind(sock, ...);
 msg_t msg[1000]; // буфера для приема сообщений
 while(true) {
   if(select(sock ... 0 сек)) {// проверка наличия входящих с таймаутом 0 сек
     size = recvfrom(sock, msg[i].buf, 1000, ...); // приняли
     msg[i].state = NEED_PARSE; // пометили на обработку
     i = (i + 1) % 1000; // берем следующий буфер
   } else {
     for(int i = 0; i < 1000) {
        if(msg[i].state == NEED_PARSE) {
          ... обработка
          sendto(sock, ...); // отправка по одному пока принимать нечего
          msg[i].state = FREE;
          break;
        }
   }
 }
}

SOCKET sock;
typedef struct {
  int state;
  char buf[1000];
} msg_t;

int main()
{
 sock = socket(AF_INET, SOCK_DGRAM, IPPROTO_UDP);
 bind(sock, ...);
 msg_t msg[1000]; // буфера для приема сообщений
 while(true) {
   if(select(sock ... 0 сек)) {// проверка наличия входящих с таймаутом 0 сек
     size = recvfrom(sock, msg[i].buf, 1000, ...); // приняли
     msg[i].state = NEED_PARSE; // пометили на обработку
     i = (i + 1) % 1000; // берем следующий буфер
   } else {
     for(int i = 0; i < 1000) {
        if(msg[i].state == NEED_PARSE) {
          ... обработка
          sendto(sock, ...); // отправка по одному пока принимать нечего
          msg[i].state = FREE;
          break;
        }
   }
 }
}

	WSADATA wsaData;
	if(WSAStartup(MAKEWORD(2, 2), &wsaData) != NO_ERROR) {
		err = 1;
	}
	#endif
	SOCKET sock = socket(AF_INET, SOCK_DGRAM, IPPROTO_UDP);
	if (!err && sock == -1) {
		err = 2;
	}
 	if(!err) {
		if(addr) {
			if(bind(sock, (SOCKADDR *) addr, (socklen_t) sizeof(sockaddr_in)) != 0) {
				err = 3;
			}
		} else {
			sockaddr_in addr_any;
			addr_any.sin_family = AF_INET;
			addr_any.sin_port = 0; //htons(0);
			addr_any.sin_addr.s_addr = 0; //htonl(INADDR_ANY);
			if(bind(sock, (SOCKADDR *) &addr_any, (socklen_t) sizeof(sockaddr_in)) != 0) {
				err = 3;
			}
		}
	}