큐로 메시지 큐 구현하기

서론

메시지 큐 방식은 윈도우 기본 프로시저에서 보내는 형태도 있고,

포트폴리오때 패킷 처리 함수를 돌릴때도 사용했다.

구조는 대충 이런 느낌으로.

큐는 내가 작성한 LinkedListQueue와 CircularQueue로 구현했다.

메시지 큐

#include <iostream>
#include <Windows.h>
#include <process.h>
#include <conio.h>
 
#include "MH_CircularQueue.h"
#include "MH_LinkedListQueue.h"
 
using namespace std;
 
// 스레드 펑션
unsigned int WINAPI ThreadFunc(void* arg);
 
// 환형 큐로 메시지 큐 전역으로 생성
// MH_CircularQueue<char> messageQueue;
 
// 링크드 리스트 큐로 메시지 큐로 전역으로 생성
MH_LinkListQueue<char> messageQueue;
 
void main(void)
{
    unsigned int threadID = 0;
 
    // 스레드 생성
    HANDLE hThread = (HANDLE)_beginthreadex(NULL, 0, ThreadFunc, 
        &messageQueue, 0, (unsigned*)&threadID);
 
    // 예외처리
    if(hThread == NULL)
    {
        cout<<"Thread Creation Fail"<<endl;
        return;
    }
 
    cout<<"Thread Creation Sucesse"<<endl;
 
    // 메뉴 출력
    cout<<"1. Message1 \n2. Message2\n3. Meesage3 \n0. exit"<<endl;
 
    // 메시지 루프
    while(true)
    {
        // 큐에 값 넣기
        messageQueue.enQueue(_getch());
    }
 
    system("pause");
}
 
// 메세지 처리 쓰레드
unsigned int WINAPI ThreadFunc(void* arg)
{
    while(true)
    {
        Sleep(1000);
        // 메시지 큐 비었는지 확인
        if(messageQueue.isEmpty() == false)
        {
            // 메시지 큐에서 가져오기
            switch(messageQueue.deQueue())
            {
            case '1':
                {
                    cout<<"Excute Message1"<<endl;
                    break;
                }
            case '2':
                {
                    cout<<"Excute Message2"<<endl;
                    break;
                }
            case '3':
                {
                    cout<<"Excute Message3"<<endl;
                    break;
                }
            case '0':
                {
                    cout<<"Exit Program"<<endl;
                    exit(0);
                }
            default:
                {
                    cout<<"Invalid Message"<<endl;
                    break;
                }
            }
        }
    }
}