- html - 出于某种原因,IE8 对我的 Sass 文件中继承的 html5 CSS 不友好?
- JMeter 在响应断言中使用 span 标签的问题
- html - 在 :hover and :active? 上具有不同效果的 CSS 动画
- html - 相对于居中的 html 内容固定的 CSS 重复背景?
我用 C 编写了一个通用队列,用于各种负载类型。它是一个阻塞队列,因此消费者线程将阻塞等待队列被生产者线程填充。
我已经使用 check
单独测试了队列代码,包括线程阻塞等待将值添加到队列的行为。所有这些测试都通过了,但是,当将队列集成到代码的其余部分时,我遇到了这样一种情况:线程第一次尝试阻塞队列时,所有其他线程都挂起。
具体来说,我正在集成的程序是一个更大生态系统的成员,因此有一个启动脚本来初始化程序,然后进行守护进程。守护线程然后创建几个分离的线程来执行各种功能。其中一个线程调用 sem_wait
,所有线程都挂起,包括生成守护进程的线程。
为确认此调用是问题所在,我使用调试器以非守护程序模式运行程序,确认 sem_wait
已挂起。在生成在队列中等待的线程之前,我还添加了一个 sleep
。在这种情况下,其他线程继续前进,然后在调用 sem_wait
时挂起。
有问题的队列只对这个程序可见。它的引用存储为全局变量。调用 sem_wait
时,队列肯定是空的。
队列代码如下:
//Queue.h
#include <pthread.h>
#include <semaphore.h>
typedef void (*freeFunction)(void *);
typedef struct _queueNode {
void *data;
struct _queueNode *next;
} queueNode;
typedef struct queue {
sem_t *logicalLength;
size_t elementSize;
queueNode *head;
queueNode *tail;
freeFunction freeFn;
pthread_mutex_t *queueLock;
} queue_t;
void queue_initialize(queue_t *queue, size_t elementSize, freeFunction freeFn);
void queue_destroy(queue_t *queue); // Removes all elements from the queue
int queue_size(queue_t *queue); // Returns the number of elements in the queue
void queue_add(queue_t *queue, void *element); // Adds to tail
int queue_take(queue_t *queue, void *elementBuffer); // Returns/removes head, blocks if empty
//Queue.c
#include <stdlib.h>
#include <string.h>
#include <assert.h>
#include <time.h>
#include "Queue.h"
void queue_initialize(queue_t *queue, size_t elementSize, freeFunction freeFn) {
assert(elementSize > 0);
assert(queue != NULL);
queue->elementSize = elementSize;
queue->head = NULL;
queue->tail = NULL;
queue->freeFn = freeFn;
queue->logicalLength = calloc(1, sizeof(sem_t));
queue->queueLock = calloc(1, sizeof(pthread_mutex_t));
sem_init(queue->logicalLength, 0, 0);
pthread_mutexattr_t attr;
pthread_mutexattr_init(&attr);
pthread_mutexattr_settype(&attr, PTHREAD_MUTEX_RECURSIVE);
pthread_mutex_init(queue->queueLock, &attr);
}
void queue_destroy(queue_t *queue) {
assert(queue != NULL);
queueNode *current;
while(queue->head != NULL) {
current = queue->head;
queue->head = current->next;
if(queue->freeFn != NULL) {
queue->freeFn(current->data);
}
free(current->data);
free(current);
}
queue->head = NULL;
queue->tail = NULL;
pthread_mutex_destroy(queue->queueLock);
sem_destroy(queue->logicalLength);
free(queue->queueLock);
free(queue->logicalLength);
}
void queue_add(queue_t *queue, void *element) {
assert(queue != NULL);
assert(element != NULL);
pthread_mutex_lock(queue->queueLock);
queueNode *node = calloc(1, sizeof(queueNode));
node->data = calloc(1, queue->elementSize);
node->next = NULL;
memcpy(node->data, element, queue->elementSize);
if(queue->head == NULL) {
queue->head = queue->tail = node;
} else {
queue->tail->next = node;
queue->tail = node;
}
sem_post(queue->logicalLength);
pthread_mutex_unlock(queue->queueLock);
}
void queue_removeNode(queue_t *queue, void *elementBuffer) {
pthread_mutex_lock(queue->queueLock);
if( queue->head == NULL ) {
pthread_mutex_unlock(queue->queueLock);
return;
}
queueNode *node = queue->head;
memcpy(elementBuffer, node->data, queue->elementSize);
if(queue->head == queue->tail)
queue->tail = NULL;
queue->head = node->next;
if(queue->freeFn) {
queue->freeFn(node->data);
}
free(node->data);
free(node);
pthread_mutex_unlock(queue->queueLock);
}
int queue_take(queue_t *queue, void *elementBuffer) {
assert(queue != NULL);
assert(elementBuffer != NULL);
int result = EXIT_SUCCESS;
sem_wait(queue->logicalLength);
queue_removeNode(queue, elementBuffer);
return result;
}
下面是暴露问题的代码:
//fei.h
...
#include "Queue.h"
extern queue_t *commandQueue;
...
//fei.c
#include "fei.h"
#include "commandHandler.h"
#include "Queue.h"
queue_t *commandQueue;
int main (int argc, char **argv){
int debugFlag = handleOpts(argc, argv);
if(!debugFlag){
int rc = daemonize();
if(rc != 0){
exit(rc);
}
}
rc = setConfigValues();
if(rc){
exit(rc);
}
queue_t *commandQueue = calloc(1, sizeof(queue_t));
queue_initialize(commandQueue, sizeof(commandPack_t), commandFree);
if(getPortIsock() == 0){ // This is a simple config value
exit(EXIT_FAILURE);
}
signal(SIGPIPE, SIG_IGN);
pthread_t id;
pthread_attr_t attr;
pthread_attr_init(&attr);
pthread_attr_setdetachstate(&attr, PTHREAD_CREATE_DETACHED);
pthread_create(&id, &attr, receiveCommands, NULL);
pthread_create(&id, &attr, processCommands, NULL);
if(!setSocketIsock()){
exit(1);
}
while(!checkIfConnectedToSct())
usleep(50000);
receiveCCSDSPackets();
exit (0);
}
// commandHandler.c
#include "Queue.h"
#include "fei.h"
#include "commandHandler.h"
queue_t *commandQueue;
void *receiveCommands(){
getNewCsockConnection();
connectedToSct = 1;
while(1){
commandPack_t cmd;
int validCommand = getCommand(CSOCKET, &cmd);
if(validCommand == RECEIVE_SUCCESS){
queue_add(commandQueue, &cmd);
} else{
usleep(5000);
}
}
return NULL;
}
void *processCommands(){
while(1){
commandPack_t cmdToProcess;
/* Blocking queue */
queue_take(commandQueue, &cmdToProcess);
switch(cmdToProcess.command){
// Command processing
}
commandFree(&cmdToProcess);
}
return NULL;
}
receiveCommands
函数是生产者线程,processCommands
函数是消费者线程。这些是代码库中唯一引用 commandQueue
的地方。虽然它是可变的,但主线程的执行很少超出 setSocketIsock()
条件检查。
欢迎任何见解。
最佳答案
在 main()
中,你有这一行:
queue_t *commandQueue = calloc(1, sizeof(queue_t));
这使得 commandQueue
成为 main
的局部变量。您的其他函数使用一个也名为 commandQueue
的全局变量。这使我认为您不打算在 main
中重新声明 commandQueue
。因此,将上面的行更改为:
commandQueue = calloc(1, sizeof(queue_t));
关于c - sem_wait 上的线程阻塞导致其他线程挂起,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/28418298/
#include using namespace std; class C{ private: int value; public: C(){ value = 0;
这个问题已经有答案了: What is the difference between char a[] = ?string?; and char *p = ?string?;? (8 个回答) 已关闭
关闭。此题需要details or clarity 。目前不接受答案。 想要改进这个问题吗?通过 editing this post 添加详细信息并澄清问题. 已关闭 7 年前。 此帖子已于 8 个月
除了调试之外,是否有任何针对 c、c++ 或 c# 的测试工具,其工作原理类似于将独立函数复制粘贴到某个文本框,然后在其他文本框中输入参数? 最佳答案 也许您会考虑单元测试。我推荐你谷歌测试和谷歌模拟
我想在第二台显示器中移动一个窗口 (HWND)。问题是我尝试了很多方法,例如将分辨率加倍或输入负值,但它永远无法将窗口放在我的第二台显示器上。 关于如何在 C/C++/c# 中执行此操作的任何线索 最
我正在寻找 C/C++/C## 中不同类型 DES 的现有实现。我的运行平台是Windows XP/Vista/7。 我正在尝试编写一个 C# 程序,它将使用 DES 算法进行加密和解密。我需要一些实
很难说出这里要问什么。这个问题模棱两可、含糊不清、不完整、过于宽泛或夸夸其谈,无法以目前的形式得到合理的回答。如需帮助澄清此问题以便重新打开,visit the help center . 关闭 1
有没有办法强制将另一个 窗口置于顶部? 不是应用程序的窗口,而是另一个已经在系统上运行的窗口。 (Windows, C/C++/C#) 最佳答案 SetWindowPos(that_window_ha
假设您可以在 C/C++ 或 Csharp 之间做出选择,并且您打算在 Windows 和 Linux 服务器上运行同一服务器的多个实例,那么构建套接字服务器应用程序的最明智选择是什么? 最佳答案 如
你们能告诉我它们之间的区别吗? 顺便问一下,有什么叫C++库或C库的吗? 最佳答案 C++ 标准库 和 C 标准库 是 C++ 和 C 标准定义的库,提供给 C++ 和 C 程序使用。那是那些词的共同
下面的测试代码,我将输出信息放在注释中。我使用的是 gcc 4.8.5 和 Centos 7.2。 #include #include class C { public:
很难说出这里问的是什么。这个问题是含糊的、模糊的、不完整的、过于宽泛的或修辞性的,无法以目前的形式得到合理的回答。如需帮助澄清此问题以便重新打开它,visit the help center 。 已关
我的客户将使用名为 annoucement 的结构/类与客户通信。我想我会用 C++ 编写服务器。会有很多不同的类继承annoucement。我的问题是通过网络将这些类发送给客户端 我想也许我应该使用
我在 C# 中有以下函数: public Matrix ConcatDescriptors(IList> descriptors) { int cols = descriptors[0].Co
我有一个项目要编写一个函数来对某些数据执行某些操作。我可以用 C/C++ 编写代码,但我不想与雇主共享该函数的代码。相反,我只想让他有权在他自己的代码中调用该函数。是否可以?我想到了这两种方法 - 在
我使用的是编写糟糕的第 3 方 (C/C++) Api。我从托管代码(C++/CLI)中使用它。有时会出现“访问冲突错误”。这使整个应用程序崩溃。我知道我无法处理这些错误[如果指针访问非法内存位置等,
关闭。这个问题不符合Stack Overflow guidelines .它目前不接受答案。 我们不允许提问寻求书籍、工具、软件库等的推荐。您可以编辑问题,以便用事实和引用来回答。 关闭 7 年前。
已关闭。此问题不符合Stack Overflow guidelines 。目前不接受答案。 要求我们推荐或查找工具、库或最喜欢的场外资源的问题对于 Stack Overflow 来说是偏离主题的,因为
我有一些 C 代码,将使用 P/Invoke 从 C# 调用。我正在尝试为这个 C 函数定义一个 C# 等效项。 SomeData* DoSomething(); struct SomeData {
这个问题已经有答案了: Why are these constructs using pre and post-increment undefined behavior? (14 个回答) 已关闭 6
我是一名优秀的程序员,十分优秀!