boost :: threadをboost :: bindで使用すると、無限ループでプログラムがハングします

Question

boost::threadpool（boost、linkの正式な部分ではありません）を使用してプログラムの特定の側面を並列化しようとしています。しかし、私はプログラムの停止と点検時に、htopは2つの非アクティブなスレッド（私はスレッドプールにあると思われます）と1つのスレッドが100％で実行されていることを示しています（私の主な実行スレッドと思われます）。ここで

は、関連するコードです：

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に電話したい場合は、その実装に投稿したリンクを簡単に見てください。