[C언어] 원형큐 예제

#define _CRT_SECURE_NO_WARNINGS
#include <stdio.h>
#include <stdlib.h>
 
int initQueue(int qSize, unsigned char* Queue);
int getQueueLeftoverSize(void);
int isQueueEmpty(void);
int isQueueFull(int queueSize);
 
 
void enqueue(unsigned char* buf, int len);
int dequeue(unsigned char* buf, int len);
 
 
int front;
int rear;
int queueSize;
unsigned char* Q;

int initQueue(int qSize, unsigned char* Queue)
{
    int ret = 1;
 
    if (Queue != NULL)    // 등록하고자 하는 큐의 주소가 NULL이 아닌경우 초기화 수행
    {
        Q = Queue;
        queueSize = qSize;
        front = 0;
        rear = 0;
        ret = 1;    // 초기화 정상 처리
    }
    else
    {
        ret = -1;    // 초기화 실패
    }
 
    return ret;
}
 
// 남아있는 데이터의 크기
int getQueueLeftoverSize(void)
{
    int ret = 0;
    if (rear > front)
        ret = rear - front;
    else
        ret = queueSize - (front - rear);
 
    return ret;
}
 
// is queue empty
int isQueueEmpty(void)
{
    int ret = 0;
 
    if (front == rear)
    {//비어있기 때문에
//        printf("queue is empty\n");
        ret = 1;
    }
    else
    {
        ret = 0;
    }
    return ret;
}
 
// is queue full
int isQueueFull(void)
{
    int ret = 0;
    if ((rear + 1) % queueSize == front)
    {
        ret = 1;
    }
    else
    {
        ret = 0;
    }
    return ret;
 
}
// enqueue
// buf(src) : Queue(Q)에 넣고자 하는 원본 데이터 배열
// len : Queue(Q)에 넣고자 하는 데이터 데이터 요소의 갯수
// return : void
//void enqueue(unsigned char* Queue, unsigned char * buf, int len)    // , int elementSize)
void enqueue(unsigned char* buf, int len)    // , int elementSize)
{
#if 0
    printf("recv data   : ");
    for (int j = 0; j < len; j++)
    {
        printf("%0.2X ", buf[j]);
    }
    printf("\n");
#endif
 
    //    printf("enqueue data :");
    for (int i = 0; i < len; i++)
    {
        if (isQueueFull() == 1)
        {
            printf("queue is full \n");
            return;
        }
        else
        {
            Q[rear] = buf[i];
            //            printf("%0.2X ", Q[rear]);
 
            rear = rear + 1;
            rear = rear % queueSize;
        }
    }
    //    printf(", front : %d, rear : %d\n", front, rear);
}
 
 
// dequeue
// buf(target) : 추출된 데이터를 저장할 데이터 버퍼
// len : 추출하기 위한 데이터 갯수
// return : dequeue 요소 갯수
//int dequeue(unsigned char * Queue, unsigned char* buf, int len)
int dequeue(unsigned char* buf, int len)
{
    int ret = 0;
 
    // 1. 큐에 남아있는 데이터가 추출하려는 데이터의 크기보다 크다면 정상 수행
    if (getQueueLeftoverSize() >= len)
    {
        // check if the queue is empty
        for (int i = 0; i < len; i++)
        {
            if (isQueueEmpty() != 1)
            {
                buf[i] = Q[front];
 
                front = front + 1;
                front = front % queueSize;
 
                ret = i + 1;
            }
            else
            {
                ret = -1;
            }
        }
    }
    else
    {
        ret = -1;
    }
    return ret;
}
 
 
// 큐에서 데이터를 빼지 않고 front에 어떤 데이터가 있는지 확인 하는 함수
unsigned char peakFrontData(void)
{
    return Q[front];
}