代码之家 › 专栏 › 技术社区 › Aditya Sehgal

一个生产者,两个消费者和pthread\u cond\u signal和pthread\u mutex\u lock的用法

mutex pthreads conditional

Aditya Sehgal · 技术社区 · 14 年前

我对pthread编程还相当陌生,我正在努力使自己的头脑清醒过来 cond_signal mutex_lock . 我正在写一个示例程序 一个生产商 螺纹和 两个消费者 线程。

我正在尝试使用pthread\u cond\u signal&pthread\u mutex\u锁定生产者和消费者之间的以下方式。

[在制作人处]

0)等待数据包到达

pthread_mutex_lock(&cons1Mux)

3) 向耗电元件1进程发送信号 pthread_cond_signal(&msgForCons1)

5) 转到步骤0

[在消费者处]

pthread\u mutex\u lock(&消耗1倍)

2) 等待信号 pthread_cond_wait(&msgForCons1,&cons1Mux)

3) 醒来后,读一下包

4) 从队列中删除。

5) 解锁互斥锁 pthread_mutex_unlock(&cons1Mux)

以上步骤正确吗?如果恰好在步骤5之后发生了从使用者线程到生产者线程的切换,那么生产者可能会发出一个数据包正在等待的信号,即使使用者还没有开始监听该信号。会不会导致“信号丢失”?

这些步骤还有其他问题吗?

1 回复 | 直到 14 年前

timday 14 年前

pthread_cond_signal

你应该做的是,在消费者中,一旦你获得了互斥,测试是否有工作要做。如果有,那么,你有一个互斥;取得所有权,更新状态,然后去做。你只需要在无事可做的情况下等待。

cannonical的例子是:

decrement_count() 
   { pthread_mutex_lock(&count_lock); 

     while (count == 0) 
        pthread_cond_wait(&count_nonzero, &count_lock); 
     count = count - 1; 
     pthread_mutex_unlock(&count_lock); 
   } 

increment_count() 
   { pthread_mutex_lock(&count_lock); 
     if (count == 0)
       pthread_cond_signal(&count_nonzero); 
     count = count + 1;
     pthread_mutex_unlock(&count_lock); 
    }

推荐文章

da cheng · 在c++11中使用条件变量使程序陷入死锁

6 年前

Eunjeong Choi · 为什么此代码返回意外结果?(条件变量)

6 年前

Lars Nielsen · 如何将互斥体用作成员变量?“simple\u encoder”的无复制构造函数被隐式删除

6 年前

Razonixx · 从线程内增加全局计数器变量,而不必等待每个线程

6 年前

spraff · 如果其他人正在等待,是否有标准的STL或Qt方法来生成互斥,否则就保留它?

6 年前

Administrator · c#-等待完成2个线程中的1个

6 年前

Francis Cugler · 删除Windows库依赖项

6 年前

AshR · 程序断断续续地使用main报告与线程本身不同的线程id

7 年前

reg · 互斥体不同步C++

7 年前

user7256215 · 在macOS内核扩展中有效地使用同步

7 年前