다른 스레드에서 벡터의 포인터 데이터를 수정하는 것이 안전합니까?

Question

일이 잘되는 것처럼 보이지만 이것이 최선의 방법인지 확신 할 수 없습니다.

기본적으로 데이터의 비동기 검색을 수행하는 개체가 있습니다. 이 객체에는 주 스레드에서 할당되고 할당 해제 된 포인터 벡터가 있습니다. 부스트 함수를 사용하면 프로세스 결과 콜백이이 벡터의 포인터 중 하나와 바인딩됩니다. 실행되면 임의의 스레드에서 실행되고 포인터의 데이터가 수정됩니다.

이제 비동기 검색 개체가 더 많은 요청을받는 경우 벡터에서 지우고 지우는 부분 주위에 중요한 섹션이 있습니다. 그러나 포인터를 수정하는 콜백에서 어떤 종류의 가드가 필요한지 궁금합니다. 데이터도 마찬가지입니다. 그것을 이것은 ProccessResults 콜백에 대한 실제 코드 (플러스 이익을 위해 댓글)

void ProcessResults(CRetrieveResults* pRetrieveResults, CRetData* data) 
     { 
// pRetrieveResults is delayed binding that server passes in when invoking callback in thread pool 
// data is raw pointer to ref counted object in vector of main thread (the DataObject* in question) 

       // if there was an error set the code on the atomic int in object 
      data->m_nErrorCode.Store_Release(pRetrieveResults->GetErrorCode()); 

       // generic iterator of results bindings for generic sotrage class item 
      TPackedDataIterator<GenItem::CBind> dataItr(&pRetrieveResults->m_DataIter); 
       // namespace function which will iterate results and initialize generic storage 
      GenericStorage::InitializeItems<GenItem>(&data->m_items, dataItr, pRetrieveResults->m_nTotalResultsFound); // this is potentially time consuming depending on the amount of results and amount of columns that were bound in storage class definition (i.e.about 8 seconds for a million equipment items in release) 
       // atomic uint32_t that is incremented when kicking off async retrieve 
      m_nStarted.Decrement(); // this one is done processing 

       // boost function completion callback bound to interface that requested results 
      data->m_complete(data->m_items); 
     } 

Answer 1

번호 :

class CAsyncRetriever 
{ 
    // typedefs of boost functions 

    class DataObject 
    { 
     // methods and members 
    }; 

public: 
    // Start single asynch retrieve with completion callback 
    void Start(SomeArgs) 
    { 
     SetupRetrieve(SomeArgs); 
     LaunchRetrieves(); 
    } 

protected: 
    void SetupRetrieve(SomeArgs) 
    { 
      // ... 

     { // scope for data lock 
      boost::lock_guard<boost::mutex> lock(m_dataMutex); 
      m_inProgress.push_back(SmartPtr<DataObject>(new DataObject))); 
      m_callback = boost::bind(&CAsyncRetriever::ProcessResults, this, _1, m_inProgress.back()); 
     } 

      // ... 
    } 

    void ProcessResults(DataObject* data) 
    { 
       // CALLED ON ANOTHER THREAD ... IS THIS SAFE? 
     data->m_SomeMember.SomeMethod(); 
       data->m_SomeOtherMember = SomeStuff; 
    } 

    void Cleanup() 
    { 
       // ... 

     { // scope for data lock 
      boost::lock_guard<boost::mutex> lock(m_dataMutex); 
      while(!m_inProgress.empty() && m_inProgress.front()->IsComplete()) 
       m_inProgress.erase(m_inProgress.begin()); 
     } 

       // ... 
     } 

private: 
    std::vector<SmartPtr<DataObject>> m_inProgress; 
    boost::mutex m_dataMutex; 
     // other members 
}; 

편집 :

는 희망이 몸매는 여전 하구나 의사 코드는 일을 더 명확하게 안전하지 않습니다.

ProcessResults은 DataObject을 통해 전달 된 데이터 구조에서 작동합니다. 이는 서로 다른 스레드간에 상태가 공유되었음을 나타내고, 두 스레드가 동시에 데이터 구조에서 작동하면 병목 현상이 발생할 수 있습니다.

Answer 2

약자로 Cleanup 코드는 ProcessResults에 대한 콜백이 수행되는 개체를 파괴 할 수 있습니다. 콜백에서 포인터를 deref 할 때 문제가 발생할 것입니다.

나의 제안은 콜백 장기 실행 경우지만, 콜백을 포함하는 당신의 m_dataMutex의 의미를 확장, 또는 때때로 이런 일이 않습니다 (SetupRetrieve 내에서 인라인 일어날 수 있다는 것이다 - 당신이 상태 비록 여기 콜백이 켜져 다른 스레드,이 경우에는 당신이 좋아) 다음 것들이 더 복잡합니다. 현재 m_dataMutex은 벡터 또는 해당 내용에 대한 액세스를 제어하는지 아니면 둘 다에 대한 액세스를 제어하는지 조금 혼란 스럽습니다. 범위가 명확 해지면 ProcessResults을 확장하여 잠금 내에서 페이로드의 유효성을 확인할 수 있습니다.

Answer 3

포인터를 업데이트하는 것은 원자 적 조작이어야하지만 InterlockedExchangePointer (Windows)을 사용하면됩니다. 리눅스에 상응하는 것이 무엇인지 모릅니다.

한 스레드가 사용되지 않는 포인터를 사용하는 경우에만 고려해야합니다. 다른 스레드가 원래 포인터가 가리키는 객체를 삭제합니까? 그렇다면 명확한 문제가 있습니다.