c++ Mutex 작업 중인데 의도대로 실행되지 않습니다..

Question

특정 디렉토리에서 파일들을 불러와 Set Container 에 입력하고 출력 및 특정 조건에 부합할 경우 파일 삭제, Container 값을 삭제하는 작업을 진행 중 입니다. 현재 코드 실행 시 main.cpp에서 thread 로 실행했음에도 불구하고 'log_manager.cpp' 에 'Log_File_Search()' 1회만 동작하거나 'Segmentation fault (core dumped)' 라는 오류문이 출력됩니다. 함수간 Set Container 사용이 문제되는 것 같은데 이리 저리 수정해봐도 문제가 해결되지 않습니다. 코드 확인해주시고 조언 부탁드립니다. /main.cpp/ #include "log_manager.h"#include pthread_t Log_File_Search_Thread;pthread_t Log_File_Send_Thread;void Log_File_Search_Thread_Function(void arg){ Log_Manager::log_manager LogManager; while (1) { LogManager.Log_File_Search(); }}void Log_File_Send_Thread_Function(void arg){ Log_Manager::log_manager LogManager; while (1) { LogManager.Log_File_Send(); }}int main(int argc, char *argv[]){ pthread_create(&Log_File_Search_Thread, NULL, Log_File_Search_Thread_Function, NULL); pthread_create(&Log_File_Send_Thread, NULL, Log_File_Send_Thread_Function, NULL); pthread_join(Log_File_Search_Thread, NULL); pthread_join(Log_File_Send_Thread, NULL); return 0;}/log_manager.h/#ifndef LOGMANAGER_H_#define LOGMANAGER_H_#include #include #include #include #include #include #include #define LOG_DIRECTORY "/oem/itronics/logs/"namespace Log_Manager{ class log_manager { private: std::set logFileName_SetContainer; std::mutex Log_File_Search_Mutex; std::condition_variable Log_File_Search_Mutex_Condition_Variable; bool Log_File_Search_Mutex_Ready = false; public: void Log_File_Search(); void Log_File_Send(); void Log_File_Delete(const std::string &logFileName); };}#endif/log_manager.cpp/#include "log_manager.h"using namespace Log_Manager;void log_manager::Log_File_Search(){ std::unique_lock locker(Log_File_Search_Mutex); Log_File_Search_Mutex_Condition_Variable.wait(locker, [this] { return !Log_File_Search_Mutex_Ready; }); DIR *dir = opendir(LOG_DIRECTORY); if (dir == nullptr) { std::cerr << "Error opening directory - " << LOG_DIRECTORY << std::endl; return; } struct dirent *entry; while ((entry = readdir(dir)) != nullptr) { std::string logFileName = entry->d_name; if (logFileName != "." && logFileName != ".." && logFileName.substr(logFileName.size() - 4) == ".log") { if (logFileName_SetContainer.find(logFileName) == logFileName_SetContainer.end()) { logFileName_SetContainer.insert(logFileName); } } } closedir(dir); Log_File_Search_Mutex_Ready = true; Log_File_Search_Mutex_Condition_Variable.notify_all();}void log_manager::Log_File_Send(){ std::unique_lock locker(Log_File_Search_Mutex); Log_File_Search_Mutex_Condition_Variable.wait(locker, [this] { return Log_File_Search_Mutex_Ready; }); for (auto it = logFileName_SetContainer.begin(); it != logFileName_SetContainer.end(); it++) { Log_File_Delete(*it); } Log_File_Search_Mutex_Ready = false; Log_File_Search_Mutex_Condition_Variable.notify_all();}void log_manager::Log_File_Delete(const std::string &logFileName){ std::string logFilePath = LOG_DIRECTORY + logFileName; if (std::remove(logFilePath.c_str()) != 0) { std::cerr << "Error deleting file: " << logFilePath << std::endl; return; } std::cout << "Deleted: " << logFilePath << std::endl; logFileName_SetContainer.erase(logFileName); std::cout << "Erased: " << logFileName << std::endl;}

ColoColo · Answer

본문에 이야기하신것처럼 set 관련 코드중에 logFileName_SetContainer 를 loop 도는 와중에 element 를 erase 해서 문제가 되는거 같네요. c++ std set erase while iterating 로 검색해보시면 수정 포인트를 찾으실 수 있을거 같습니다.별개로, Log_File_Search_Thread_Function와 Log_File_Send_Thread_Function 함수안에서 각각 LogManager instance를 따로 생성하는데, 두 함수에서 같은 instance를 사용하게 수정해야 원하는 동작이 될거 같네요.

saki_ · Answer

주어진 코드에서 발생하는 문제는 주로 다음과 같습니다:1. *Log_File_Search_Thread_Function 및 Log_File_Send_Thread_Function 함수의 시그니처가 올바르지 않습니다.* pthread_create를 사용할 때, 함수 포인터는 `void (start_routine)(void*)` 형식을 가져야 합니다.2. *잠금 및 조건 변수 사용의 논리적 오류*. 조건 변수를 사용하여 스레드 간의 동기화를 구현하려고 하지만, Log_File_Search_Mutex_Ready 플래그와 조건 변수의 올바른 사용이 필요합니다.3. *정적 멤버 변수를 사용하지 않고 인스턴스 멤버 변수를 사용*. 이는 여러 스레드에서 log_manager 인스턴스를 공유할 때 문제가 될 수 있습니다.이 문제들을 해결하기 위해 아래와 같은 수정이 필요합니다:1. *스레드 함수 시그니처 수정: `void를 반환하고 인자로 void*`를 받아야 합니다.2. *잠금 및 조건 변수 사용 수정*: 동기화 논리를 수정하여 올바르게 동작하도록 합니다.수정된 코드는 다음과 같습니다:### main.cpp```cpp#include "log_manager.h"#include pthread_t Log_File_Search_Thread;pthread_t Log_File_Send_Thread;void Log_File_Search_Thread_Function(void arg) { Log_Manager::log_manager LogManager = static_cast(arg); while (true) { LogManager->Log_File_Search(); } return nullptr;}void Log_File_Send_Thread_Function(void arg) { Log_Manager::log_manager LogManager = static_cast(arg); while (true) { LogManager->Log_File_Send(); } return nullptr;}int main(int argc, char *argv[]) { Log_Manager::log_manager LogManager; pthread_create(&Log_File_Search_Thread, nullptr, Log_File_Search_Thread_Function, &LogManager); pthread_create(&Log_File_Send_Thread, nullptr, Log_File_Send_Thread_Function, &LogManager); pthread_join(Log_File_Search_Thread, nullptr); pthread_join(Log_File_Send_Thread, nullptr); return 0;}```### log_manager.h```cpp#ifndef LOGMANAGER_H_#define LOGMANAGER_H_#include #include #include #include #include #include #include #define LOG_DIRECTORY "/oem/itronics/logs/"namespace Log_Manager {class log_manager {private: std::set logFileName_SetContainer; std::mutex Log_File_Search_Mutex; std::condition_variable Log_File_Search_Mutex_Condition_Variable; bool Log_File_Search_Mutex_Ready = false;public: void Log_File_Search(); void Log_File_Send(); void Log_File_Delete(const std::string &logFileName);};}#endif```### log_manager.cpp```cpp#include "log_manager.h"using namespace Log_Manager;void log_manager::Log_File_Search() { std::unique_lock locker(Log_File_Search_Mutex); while (Log_File_Search_Mutex_Ready) { Log_File_Search_Mutex_Condition_Variable.wait(locker); } DIR* dir = opendir(LOG_DIRECTORY); if (dir == nullptr) { std::cerr << "Error opening directory - " << LOG_DIRECTORY << std::endl; return; } struct dirent* entry; while ((entry = readdir(dir)) != nullptr) { std::string logFileName = entry->d_name; if (logFileName != "." && logFileName != ".." && logFileName.substr(logFileName.size() - 4) == ".log") { if (logFileName_SetContainer.find(logFileName) == logFileName_SetContainer.end()) { logFileName_SetContainer.insert(logFileName); } } } closedir(dir); Log_File_Search_Mutex_Ready = true; Log_File_Search_Mutex_Condition_Variable.notify_all();}void log_manager::Log_File_Send() { std::unique_lock locker(Log_File_Search_Mutex); while (!Log_File_Search_Mutex_Ready) { Log_File_Search_Mutex_Condition_Variable.wait(locker); } for (auto it = logFileName_SetContainer.begin(); it != logFileName_SetContainer.end(); ) { Log_File_Delete(*it); it = logFileName_SetContainer.erase(it); // erase returns the iterator to the next element } Log_File_Search_Mutex_Ready = false; Log_File_Search_Mutex_Condition_Variable.notify_all();}void log_manager::Log_File_Delete(const std::string &logFileName) { std::string logFilePath = LOG_DIRECTORY + logFileName; if (std::remove(logFilePath.c_str()) != 0) { std::cerr << "Error deleting file: " << logFilePath << std::endl; return; } std::cout << "Deleted: " << logFilePath << std::endl;}```이제 main.cpp에서 스레드 함수가 올바른 시그니처를 가지고 있고, log_manager의 동기화 메커니즘이 적절하게 구현되었습니다. 이 변경 사항을 적용한 후 코드가 의도한 대로 작동하는지 확인해보세요.

c++ Mutex 작업 중인데 의도대로 실행되지 않습니다..

2개의 답변

#ubuntu18.04 목록