资兴做网站公司,东莞网络公司网站建设,成都网络运营外包,杭州知名电商代运营公司在C语言中#xff0c;队列是一种常用的数据结构#xff0c;特别适用于嵌入式开发中的任务调度、缓冲区管理等场景。下面是一个简单的循环队列的模板代码#xff0c;它使用数组来实现队列#xff0c;并提供了基本的入队#xff08;enqueue#xff09;和出队#xff08;de…在C语言中队列是一种常用的数据结构特别适用于嵌入式开发中的任务调度、缓冲区管理等场景。下面是一个简单的循环队列的模板代码它使用数组来实现队列并提供了基本的入队enqueue和出队dequeue操作。
示例代码如下
#include stdio.h
#include stdbool.h
#include string.h #define QUEUE_MAX_SIZE 10 // 定义队列的最大容量 // 队列的结构体定义
typedef struct { int data[QUEUE_MAX_SIZE]; // 存储队列元素的数组如果需要动态扩展队列容量可以考虑使用链表来实现队列 int front; // 队列头部的索引 int rear; // 队列尾部的索引
} Queue; // 初始化队列
void queueInit(Queue *q) { q-front q-rear 0;
} // 判断队列是否为空
bool isQueueEmpty(Queue *q) { return q-front q-rear;
} // 判断队列是否已满
bool isQueueFull(Queue *q) { return (q-rear 1) % QUEUE_MAX_SIZE q-front;
} // 入队操作
bool enqueue(Queue *q, int value) { if (isQueueFull(q)) { return false; // 队列已满无法入队 } q-data[q-rear] value; q-rear (q-rear 1) % QUEUE_MAX_SIZE; return true;
} // 出队操作
bool dequeue(Queue *q, int *value) { if (isQueueEmpty(q)) { return false; // 队列为空无法出队 } *value q-data[q-front]; q-front (q-front 1) % QUEUE_MAX_SIZE; return true;
} // 打印队列中的所有元素
void printQueue(Queue *q) { int i q-front; for (int count 0; count (q-rear - q-front QUEUE_MAX_SIZE) % QUEUE_MAX_SIZE; count) { printf(%d , q-data[i]); i (i 1) % QUEUE_MAX_SIZE; } printf(\n);
} // 主函数演示队列的使用
int main() { Queue q; queueInit(q); // 入队操作 enqueue(q, 1); enqueue(q, 2); enqueue(q, 3); // 打印队列 printf(Queue after enqueue: ); printQueue(q); // 出队操作 int value; dequeue(q, value); printf(Dequeued value: %d\n, value); // 再次打印队列 printf(Queue after dequeue: ); printQueue(q); return 0;
}
这段代码定义了一个队列结构体包括一个整型数组来存储队列元素以及两个索引来分别表示队列的头部和尾部。 enqueue 函数用于在队列尾部添加元素 dequeue 函数用于从队列头部移除元素。 isQueueEmpty 和 isQueueFull 函数分别用于检查队列是否为空或满。
但是这个队列实现是线程不安全的。在多线程环境中使用时需要添加适当的同步机制来避免竞态条件。
考虑引入同步机制帮助解决上述队列实现中的不安全问题 1.互斥锁Mutex: 互斥锁是一种基本的同步机制用于保护共享资源不被多个线程同时访问。在队列操作中可以在入队和出队操作前后使用互斥锁来确保每次只有一个线程可以修改队列。 #include pthread.h
pthread_mutex_t queue_mutex PTHREAD_MUTEX_INITIALIZER;
bool enqueue(Queue *q, int value) { pthread_mutex_lock(queue_mutex); if (isQueueFull(q)) { pthread_mutex_unlock(queue_mutex); return false; } q-data[q-rear] value; q-rear (q-rear 1) % QUEUE_MAX_SIZE; pthread_mutex_unlock(queue_mutex); return true; }
bool dequeue(Queue *q, int *value) { pthread_mutex_lock(queue_mutex); if (isQueueEmpty(q)) { pthread_mutex_unlock(queue_mutex); return false; } *value q-data[q-front]; q-front (q-front 1) % QUEUE_MAX_SIZE; pthread_mutex_unlock(queue_mutex); return true; } 2.条件变量Condition Variable: 条件变量可以与互斥锁一起使用以实现更高级的同步机制。它们允许线程在某些条件不满足时挂起直到其他线程发出信号。 #include pthread.h
pthread_mutex_t queue_mutex PTHREAD_MUTEX_INITIALIZER; pthread_cond_t queue_not_full PTHREAD_COND_INITIALIZER; pthread_cond_t queue_not_empty PTHREAD_COND_INITIALIZER;
bool enqueue(Queue *q, int value) { pthread_mutex_lock(queue_mutex); while (isQueueFull(q)) { pthread_cond_wait(queue_not_full, queue_mutex); // 等待队列有空间 } q-data[q-rear] value; q-rear (q-rear 1) % QUEUE_MAX_SIZE; pthread_cond_signal(queue_not_empty); // 通知可能有线程在等待出队 pthread_mutex_unlock(queue_mutex); return true; }
bool dequeue(Queue *q, int *value) { pthread_mutex_lock(queue_mutex); while (isQueueEmpty(q)) { pthread_cond_wait(queue_not_empty, queue_mutex); // 等待队列中有元素 } *value q-data[q-front]; q-front (q-front 1) % QUEUE_MAX_SIZE; pthread_cond_signal(queue_not_full); // 通知可能有线程在等待入队 pthread_mutex_unlock(queue_mutex); return true; } 3.读写锁Read-Write Lock: 如果队列的读操作远多于写操作使用读写锁可以提高性能。读写锁允许多个读操作同时进行但写操作会独占锁。 #include pthread.h
pthread_rwlock_t queue_rwlock PTHREAD_RWLOCK_INITIALIZER;
bool enqueue(Queue *q, int value) { pthread_rwlock_wrlock(queue_rwlock); if (isQueueFull(q)) { pthread_rwlock_unlock(queue_rwlock); return false; } // ... 入队操作 pthread_rwlock_unlock(queue_rwlock); return true; }
bool dequeue(Queue *q, int *value) { pthread_rwlock_wrlock(queue_rwlock); if (isQueueEmpty(q)) { pthread_rwlock_unlock(queue_rwlock); return false; } // ... 出队操作 pthread_rwlock_unlock(queue_rwlock); return true; }
void printQueue(Queue *q) { pthread_rwlock_rdlock(queue_rwlock); // ... 打印队列操作 pthread_rwlock_unlock(queue_rwlock); } 4.原子操作: 某些编译器或硬件平台提供了原子操作可以直接在不使用锁的情况下保证操作的原子性。这可以减少锁的开销但通常只适用于简单的操作。 最后需要注意使用这些同步机制时需要确保正确地初始化和销毁它们并且在适当的时候获取和释放锁。同时还需要考虑死锁的可能性并采取相应的预防措施。
