我想轮询数据形式外部硬件并通过信号发送数据。boost信号量导致段错误
我的代码导致段错误,当在共享内存中的smaphore等待被调用,我不明白为什么。
下面是我正在做的一个小例子。 基本上启动两个boost线程,一个在共享内存中写入数据,另一个在共享内存中读取数据。
主要只是启动ThreadHandler,睡并停止ThreadHandler。
头:
struct SharedData{
boost::interprocess::interprocess_semaphore sem;
int data;
bool newData;
SharedData():sem(1),newData(false){}
};
class ThreadHandler
{
public:
ThreadHandler();
void start();
void stop();
boost::thread *m_Thread;
boost::thread *m_doerThread;
void doStuff();
void createSharedMemory();
void removeSharedMemory();
SharedData* m_sharedMemory;
};
来源:
void getStuff(int id);
void ThreadHandler::start(){
createSharedMemory();
m_doerThread = new boost::thread(boost::bind(&ThreadHandler::doStuff,boost::ref(*this)));
m_Thread = new boost::thread(boost::bind(&getStuff,1));
}
void ThreadHandler::stop(){
m_Thread->interrupt();
m_doerThread->interrupt();
m_Thread->join();
m_doerThread->join();
}
void ThreadHandler::createSharedMemory(){
removeSharedMemory();
try{
boost::interprocess::shared_memory_object sharedObj(boost::interprocess::create_only,SHARED_MEMORY ,boost::interprocess::read_write);
sharedObj.truncate(sizeof(SharedData));
boost::interprocess::mapped_region mappedObj(sharedObj,boost::interprocess::read_write);
SharedData* helper = (SharedData*)mappedObj.get_address();
m_sharedMemory = new (helper) SharedData;
}catch(boost::interprocess::interprocess_exception &ex){
std::cout<<ex.what()<<std::endl;
}catch(std::exception &ex){
std::cout<<ex.what()<<std::endl;
}
}
void ThreadHandler::removeSharedMemory(){
boost::interprocess::shared_memory_object::remove(SHARED_MEMORY);
}
void ThreadHandler::doStuff(){
while(1){
try{
boost::this_thread::yield();
m_sharedMemory->sem.wait();
while(!m_sharedMemory->newData){
m_sharedMemory->sem.post();
boost::this_thread::interruption_point();
boost::this_thread::yield();
m_sharedMemory->sem.wait();
}
//doStuff
m_sharedMemory->newData=false;
m_sharedMemory->sem.post();
}catch(boost::thread_interrupted &interupt){
break;
}catch(std::exception &ex){
std::cout<<ex.what()<<std::endl;
}catch(...){
std::cout<<"exception"<<std::endl;
}
}
}
void getStuff(int id){
SharedData* m_sharedMemory;
try{
boost::interprocess::shared_memory_object sharedObj(boost::interprocess::open_only,SHARED_MEMORY,boost::interprocess::read_write);
boost::interprocess::mapped_region mappedObj(sharedObj,boost::interprocess::read_write);
m_sharedMemory = static_cast<SharedData*>(mappedObj.get_address());
}catch(std::exception &ex){
std::cout<<ex.what()<<std::endl;
}
while(1){
try{
//get Data from hardware
int i =1;
m_sharedMemory->sem.wait();
while(m_sharedMemory->newData){
m_sharedMemory->sem.post();
boost::this_thread::interruption_point();
boost::this_thread::yield();
m_sharedMemory->sem.wait();
}
memcpy(&(m_sharedMemory->data),&i,sizeof(int));
m_sharedMemory->newData=true;
m_sharedMemory->sem.post();
}catch(boost::thread_interrupted&){
break;
}catch(std::exception &ex){
std::cout<<ex.what()<<std::endl;
}
}
}
我已经尝试提升和std互斥具有相同的结果。 我处理共享/映射的内存有问题吗?
什么是与所有的指针,而不是释放对象时动态分配?你来自Java还是C#背景? –
对不起,我必须在发帖前删除它们 – user7236868