我正在使用pthread开发一个多线程的C语言应用程序。其中一个线程将数据写入数据库（数据库库只能在单个线程中安全使用），而其他几个线程则收集数据、处理数据，然后需要将结果发送给数据库线程进行存储。我看到有人提到在C语言中可以实现“多写者安全队列”，但每次看到这样的提及时都说“对于这个示例来说太复杂了”，并且只是演示一个“单写者安全队列”。
我需要以下内容：
编辑：读取线程不应该在空队列上旋转，因为在没有写入的情况下可能会有几分钟的时间，而在短时间内会有大量的写入。
当然，有一些无锁队列。但根据您在评论中所说的情况来看，性能并不是非常关键，因为您无论如何都要为每个写操作创建一个线程。
因此，这是条件变量的标准用例。请创建一个包含互斥量、条件变量、链表（或循环缓冲区，如果您喜欢），以及取消标志的结构体：
write:
lock the mutex
(optionally - check the cancel flag to prevent leaks of stuff on the list)
add the event to the list
signal the condition variable
unlock the mutex
read:
lock the mutex
while (list is empty AND cancel is false):
wait on the condition variable with the mutex
if cancel is false: // or "if list non-empty", depending on cancel semantics
remove an event from the list
unlock the mutex
return event if we have one, else NULL meaning "cancelled"
cancel:
lock the mutex
set the cancel flag
(optionally - dispose of anything on the list, since the reader will quit)
signal the condition variable
unlock the mutex
如果你正在使用带有外部节点的列表，那么你可能希望在互斥锁之外分配内存，以减少保持时间。但如果你使用了一个具有侵入式列表节点的事件，那可能是最简单的。
编辑：如果在取消操作中将“signal”更改为“broadcast”，则还可以支持多个读取器（对于哪个读取器获取给定事件没有可移植的保证）。虽然你不需要它，但这样做也不会产生额外的代价。
Mutex myQueueLock;
Queue myQueue;
void mtQueuePush(int value)
{
lock(myQueueLock);
queuePush(myQueue, value);
unlock(myQueueLock);
}
int mtQueueNext()
{
lock(myQueueLock);
int value = queueFront(myQueue);
queuePop(myQueue);
unlock(myQueueLock);
return value;
}
接下来需要做的是，在队列为空时添加mtQueueNext的处理。
编辑： 如果您有一个单读单写无锁队列，您只需要在mtQueuePush周围加一个锁，以防止多个同时写入者。
有许多单读单写无锁队列，然而大部分都是用C++模板类实现的。但是请通过谷歌搜索并在必要时学习如何将它们改写为纯C语言实现。
- 多个写入者意味着多个push()线程。
- 无锁并不是必须的，但如果有的话会很好。
- 并发写入完全是可能的，虽然不太可能。 （即没有隐含保证不会有并发写入，但如果一个或多个阻塞直到其中一个完成，那也不是一个大问题。）
- Edward