生产者消费者使用PTHreads和Semaphore的同步错误
synchronization error in producer consumer using pthreads and semaphore
我已经使用pthreads和semaphores编写了一个简单的生产者消费者。有时我会失去订单(在生产者生产之前消费者消费)输出。请帮助我找到问题。我已经使用各种来源和教程验证了逻辑,但仍会获得不希望的结果。
#include <iostream>
#include <pthread.h>
#include <semaphore.h>
#include <string>
#include <sstream>
#include <unistd.h>
#include "pthread_barrier.hpp"
sem_t empty;
sem_t full;
sem_t lock;
pthread_mutex_t wlock;
pthread_barrier_t pbarrier;
pthread_barrier_t cbarrier;
pthread_attr_t tattr;
#define BUFF_SIZE 100
volatile bool buffer[BUFF_SIZE];
int prodIterator = 0;
int consIterator = 0;
void *Producer(void *args)
{
pthread_barrier_wait(&pbarrier);
while(1) {
sem_wait(&empty);
sem_wait(&lock);
buffer[prodIterator] = true;
pthread_mutex_lock(&wlock);
std::stringstream str;
std::cout<<"producer produced = "<<prodIterator<<"n";
pthread_mutex_unlock(&wlock);
prodIterator = (++prodIterator)% BUFF_SIZE;
sem_post(&lock);
sem_post(&full);
sleep(1);
}
}
void *Consumer(void *args)
{
pthread_barrier_wait(&cbarrier);
while(1) {
sem_wait(&full);
sem_wait(&lock);
buffer[consIterator] = false;
pthread_mutex_lock(&wlock);
std::cout<<"Consumer consumed = "<<consIterator<<"n";
pthread_mutex_unlock(&wlock);
consIterator = (++consIterator)% BUFF_SIZE;
sem_post(&lock);
sem_post(&empty);
sleep(1);
}
}
int main()
{
sem_init(&empty, 0, BUFF_SIZE);
sem_init(&full, 0, 0);
sem_init(&lock, 0, 1);
pthread_mutex_init(&wlock, NULL);
pthread_t prod[10];
pthread_t cons[10];
unsigned pcount = 5;
unsigned ccount = 2;
pthread_barrier_init(&pbarrier, NULL, pcount);
pthread_barrier_init(&cbarrier, NULL, ccount);
pthread_attr_init(&tattr);
pthread_attr_setdetachstate(&tattr, PTHREAD_CREATE_DETACHED);
for(int i=0;i<5;i++) {
pthread_create(&prod[i], &tattr, Producer, NULL);
}
for(int i=0;i<2;i++) {
pthread_create(&cons[i], &tattr, Consumer, NULL);
}
pthread_exit(NULL);
}
我发现了问题。我使用的是Mac OSX,Mac OSX不支持未包含的emaphores。它仅支持命名的信号量。因此,代替我的代码中使用未命名的信号量,我需要用命名的信号量替换它以使代码工作。OSX对Pthreads的支持很差。它也不支持Pthread障碍。 因此,我需要用以下方式替换信号量的初始线。
full = sem_open("/semaphore1", O_CREAT, 0777, 1);
empty = sem_open("/semaphore2", O_CREAT, 0777, 1);
lock = sem_open("/semaphore3", O_CREAT, 0777, 1);
and the declaration of semaphore variables needed be replace by :
sem_t *empty;
sem_t *full;
sem_t *lock;
very poor support indeed for pthreads in mac osx
相关文章:
- 松弛原子与无同步情况下的记忆连贯性
- 使用QQuickFramebufferObject时同步数据的最佳方式是什么
- 在C++中同步线程
- 与 stdio 同步是否使程序 I/O 非交互式?
- 如何在qt中同步应用程序和显示器的刷新率?
- Windows 进程间同步类似事件?
- 当对套接字 send() 的同步调用由于连接另一端丢失而被阻止时,如何恢复?
- 将 10 个线程与原子布尔值同步
- ofstream::close() 是否在 Linux 上调用同步?
- 与Visual Studios(c ++)同步时如何组织github存储库?
- 原子获取是否与互斥锁释放同步?
- Boost (Beast) websocket:同步写入挂起
- Postgres vs MySQL:命令不同步;.
- 线程过程中的线程同步问题
- 同步读取多个 TCP 响应
- 同步两个具有不同帧速率的传感器
- 如何定期同步线程?
- 同步对多个向量进行排序
- 同步类中的公共变量
- 生产者消费者使用PTHreads和Semaphore的同步错误