boost :: bind를 boost :: bind와 함께 사용하면 무한 루프에서 프로그램이 중단됩니다.

Question

boost::threadpool (boost, link의 공식 파트가 아님)을 사용하여 프로그램의 특정 부분을 병렬 처리하려고합니다. 그러나, 내 프로그램 실속 및 검사시, 두 개의 비활성 스레드 (내 스레드 풀에서 용의자가) 및 하나의 스레드를 100 % (내 주 실행 스레드 용의자)에서 실행되는 나를 보여줍니다 htop 보여줍니다. 여기

는 관련 코드 :

namespace rt { 

class Renderer 
{ 
    public: 
    Renderer(int threads) : tp(threads) {} 

    void render(const Scene&, const Camera&, Image&) const; 

    private: 
    mutable boost::threadpool::pool tp; 
    //int tp; 

    static void render(const Scene&, const Camera&, Image&, int, int); 
    static Color trace_ray(const Ray&, const Scene&, int depth = 0); 
}; 

} // namespace rt

void 
Renderer::render(const Scene& scene, const Camera& cam, Image& image) const 
{ 
    for (int y = 0; y < image.get_height(); ++y) 
     for (int x = 0; x < image.get_width(); ++x) 
      tp.schedule(boost::bind(&Renderer::render, scene, cam, image, x, y)); 

    tp.wait(); 
} 

void 
Renderer::render(const Scene& scene, const Camera& cam, Image& image, int x, int y) 
{ 
    Color c = trace_ray(cam.spawn_ray(x + .25f, y + .25f), scene) 
      + trace_ray(cam.spawn_ray(x + .75f, y + .25f), scene) 
      + trace_ray(cam.spawn_ray(x + .25f, y + .75f), scene) 
      + trace_ray(cam.spawn_ray(x + .75f, y + .75f), scene); 

    image.set_pixel(x, y, c/4.0f); 
}

나는 문제가 내 boost::bind 구조로 거짓말을 의심하는 이유는 내가 void foobar() {} 기능을 만들고 boost::threadpool::pool::schedule에이를 통과 할 때, 프로그램은하지 않는다는 것입니다 그것에 무한 루프가 있습니다. 여기서 내가 뭘 잘못하고 있니?

Answer 1

주어진 인수는 boost::bindwill be copied입니다. 복사하여 내부적으로 에 의해 개최한다 결합

인수는 함수 객체를 반환했습니다. 예를 들어 다음 코드에서 을 입력하십시오.

int i = 5;

bind (f, i, _1); i 값의 사본이 함수 오브젝트에 저장됩니다. boost :: ref 및 boost :: cref는 복사본이 아닌 함수 개체 저장을 개체에 저장하는 데 사용할 수 있습니다. 귀하의 경우에는

:

tp.schedule(boost::bind(&Renderer::render, scene, cam, image, x, y)); 

이 cam, image, x 및 y-Rendered::render의 사본을 보내드립니다. 그게 네가 원하는거야?

Answer 2

대신에 boost :: thread_group을 즉석 스레드 풀로 사용 하시겠습니까? 여기서 wait()의 구현은 이름이 스레드가 무한정 비활성 상태가되는 이유가 될 수있는 장벽을 의미합니다.

편집 :

당신이 무한 루프에 가지 않고 렌더링 호출 할 수 있습니까? 아마도 그것은 당신이 보이지 않는 광선을 추적하거나 산란하는 방식 일 것입니다. 또한 스레드 풀에 wait_for_all_tasks으로 전화를 걸려면 구현에 게시 한 링크를 잠시 훑어 보면됩니다.