2
私はポーリングデータから外部ハードウェアを作成し、そのデータを信号で送信します。ブーストセマフォー原因segfault
私のコードは、共有メモリのsmaphoreで呼び出されるのを待っているときにsegfaultを引き起こし、なぜその理由が分かりません。
以下、私がやっていることの小さな例です。 基本的に2つのブースト・スレッドを開始します.1つは共有メモリーにデータを書き込み、もう1つはデータを読み込みます。
メインは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;
};
源：私はすでに同じ結果とブーストとstdミューテックスを試みた
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;
}
}
}
。 共有/マップされたメモリを間違って処理しますか？ここで
は、すべてのポインタをどうだ、とあなたが動的に割り当てるオブジェクトを解放しませんか？あなたはJavaやC＃の背景ですか？ –
私はそれについて残念です、投稿する前にそれらを削除しておく必要があります – user7236868