스레드를 생성 할 때 boost :: thread 런타임 오류가 발생했습니다.

Question

스레드를 사용하여 모든 작업을 빠르게 처리 할 수있는 프로젝트가 있습니다. 우리는 개별 스레드에서이 함수를 호출 할 수 있도록하려면 :

Request& Filter::processRequest(Request& req) 

그러므로 나는 반환 값에 액세스 할 수 있도록 람다 식의 기능을 포장.

는 이제 다음과 같은 런타임 오류가 발생합니다 :

glibc detected ... double free or corruption (!prev): ... 

나는 모든 것이 잘 작동 그룹에 스레드를 추가하려면 행의 주석을 해제합니다.

boost::thread_group thread; 
for (std::set<boost::shared_ptr<Filter> >::iterator i = sources_.begin(); 
    i != sources_.end(); ++i) { 
     Request ret 
     thread.add_thread(new boost::thread(boost::lambda::var(ret) = 
      (*i)->processRequest(req))); 
     req+=ret; 
     ... 
} 
thread.join_all(); 

이 런타임 오류의 원인은 무엇 일 수 있습니다. 아니면 개별 스레드에이 함수를 넣는 다른 방법이 있습니까?

Answer 1

이런 종류의 기술이 전혀 작동하지 않는다면 안정적으로 참조 할 수있는 여러 개의 ret 값 (각 실행 스레드마다 하나씩)이 필요합니다. 그리고 당신은 당신이 그 값을 사용할 때까지 당신의 스레드 조인이 완료 될 때까지 기다려야 할 것입니다.

간단한 수정을하면 vector<Request> retValues ... 루프 외부의 벡터를 만든 다음 add_thread 때마다 요소를 벡터에 추가하고 해당 요소에 대한 참조를 전달할 수 있습니다. 그런 다음 값을 사용하기 위해 조인이 끝날 때까지 기다리면 아마도 작동할까요?

boost::thread_group thread; 
vector<Request> retValues; 
for (std::set<boost::shared_ptr<Filter> >::iterator i = sources_.begin(); 
    i != sources_.end(); ++i) { 
     retValues.push_back(0); 
     thread.add_thread(new boost::thread(
      boost::lambda::var(retValues.back()) = 
      (*i)->processRequest(req))); 
     ... 
} 
thread.join_all(); 
// retValues safe to use here... 

(참고 : boost::lambda를 사용하는 것은 아마 필요가 없습니다, 당신은 결과를 저장하는 노동자 클래스에 연결하는 부스트 : : 바인딩을 사용할 수 있습니다 : 정말

Getting return value from a boost::threaded member function?

을 ...하지만, 결과를 저장하기 위해 스레드마다 별도의 변수가 필요합니다 ... 스레드의 수명이 스레드에서 쓸 수있을만큼 오래 지속됩니다.)