我想輪詢數據形式外部硬件並通過信號發送數據。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