任务队列简单实现

实用场景:

例子1：

例子2：

     生产者-----消费者   之间

.h

#ifndef __TASK_QUEUE_H__
#define __TASK_QUEUE_H__

typedef struct Task
{
	void* (*run)(void *);	// 任务处理函数
	void* param;			// 附加参数
}Task_t;

typedef struct Task_queue
{
	int head;		// 队列头
	int tail;		// 队列尾
	int size;		// 实际任务数量
	int capcity;	// 任务最大个数
	Task_t*  tasks;	// 任务
}Task_queue_t;


// 建立队列
// size:任务大小
Task_queue_t *queue_create(int size);

// 队列是否满了
bool queue_is_full(Task_queue_t* tq);

// 队列是否为空
bool queue_is_empty(Task_queue_t* tq);

// 将任务添加到任务队列尾部
bool queue_push_tail(Task_queue_t* tq, Task_t* t);

// 取出任务队列头部任务
Task_t* queue_pop_head(Task_queue_t* tq);

// 释放申请的任务队列
void queue_free(Task_queue_t* tq);

#endif

.cpp

#include "taskQueue.h"
#include <stdlib.h>

#define DEFAULT_QUEUE_SIZE 65535

Task_queue_t* queue_create(int size)
{
	// 建立队列结构
	Task_queue_t *tq = (Task_queue_t *)malloc(sizeof(Task_queue_t));
	if (tq != nullptr)
	{
		if (size > 0)
		{
			// 建立任务结构
			tq->tasks = (Task_t *)malloc(size * sizeof(Task_t));
			tq->capcity = size;
		}
		else
		{
			int default_size = DEFAULT_QUEUE_SIZE;
			tq->tasks = (Task_t *)malloc(default_size * sizeof(Task_t));
			tq->capcity = default_size;
		}

		if (tq->tasks == nullptr)
		{
			free(tq);
			return nullptr;
		}

		tq->head = tq->tail = tq->size = 0;
	}

	return tq;
}

bool queue_is_full(Task_queue_t* tq)
{
	return tq->size == tq->capcity;
}

bool queue_is_empty(Task_queue_t* tq)
{
	return tq->size == 0;
}

bool queue_push_tail(Task_queue_t* tq, Task_t* t)
{
	if (!queue_is_full(tq))
	{
		tq->tasks[tq->tail].run = t->run;
		tq->tasks[tq->tail].param = t->param;

		//tq->tail++; 错误示范  这样没法复用

		// 当任务满最大值时，取出最前面任务后,
		// 当又须要添加新的任务时能够复用前面的任务结构
		tq->tail = (tq->tail + 1) % (tq->capcity);
		
		tq->size++;
		return true;
	}

	return false;
}

Task_t* queue_pop_head(Task_queue_t* tq)
{
	Task_t* t = nullptr;
	if (!queue_is_empty(tq))
	{
		t = &(tq->tasks[tq->head]);

		//tq->head--; 错误 这样没法复用
		tq->head = (tq->head + 1) % (tq->capcity);

		tq->size--;
	}

	return t;
}

void queue_free(Task_queue_t* tq)
{
	if (tq != nullptr)
	{
		free(tq->tasks);
		free(tq);
	}
}

注意：其余线程使用时注意push,pop须要同步!