thread程序会导致很多竞争条件

我有一个程序，我使用boost::threads多线程。不幸的是，drd (valgrind --tool=drd ./my_program)报告了许多关于10000的问题。

我不确定我是否误解了boost线程的一些东西。我试着找出我的错误了几个小时，但没有得到更多，因此任何帮助都将是感激的。

我尝试管道某些过滤器，并希望能够运行它们通过调用最后一个过滤器运行。然后，这个过滤器应该首先调用他所依赖的所有前体过滤器，最后调用他的processQueue()方法。我现在想要能够在它们的线程中调用前驱过滤器，这样如果图是并行路径，我就能得到一个加速。因此，我添加了threadgroup，以便每个前驱过滤器在自己的线程中执行。但不幸的是，我得到了很多竞争条件，我不确定他们的结果。我希望现在我想要达到的目标更明确了。

我已经将代码更新为一个更简单的代码，问题仍然发生。我认为这个问题与线程生成有关。

更新2

我认为这些的主要原因是valgrind的假阳性率非常高。我对此提出了一个新问题。看到

更新3

当我使用valgrind 3.6.1而不是3.7.0或3.8.0时，大多数错误都可以避免。

这里有一份drd报告:

==29905== Conflicting load by thread 1 at 0xb0081000 size 8
==29905==    at 0x25A6C2: pthread_join (in /usr/lib/system/libsystem_c.dylib)
==29905==    by 0x2BEC0: boost::thread::join() (in /usr/local/lib/libboost_thread.dylib)
==29905==    by 0x100006641: Filter::run() (in ./playgroudThreads)
==29905==    by 0x100001013: main (in ./playgroudThreads)
==29905== Allocation context: unknown.
==29905== Other segment start (thread 2)
==29905==    at 0x2A7B68: thread_start (in /usr/lib/system/libsystem_c.dylib)
==29905== Other segment end (thread 2)
==29905==    at 0x3E667A: mach_msg_trap (in /usr/lib/system/libsystem_kernel.dylib)
==29905==    by 0x3DED38: semaphore_create (in /usr/lib/system/libsystem_kernel.dylib)
==29905==    by 0x2A50F7: new_sem_from_pool (in /usr/lib/system/libsystem_c.dylib)
==29905==    by 0x2A6199: _pthread_exit (in /usr/lib/system/libsystem_c.dylib)
==29905==    by 0x2A48C9: _pthread_start (in /usr/lib/system/libsystem_c.dylib)
==29905==    by 0x2A7B74: thread_start (in /usr/lib/system/libsystem_c.dylib)

这里是我的示例代码:

#include <iostream>
#include <vector>
#include <sys/time.h>
#include <boost/thread.hpp>
#include <boost/bind.hpp>
class Filter
{
    public:
        Filter(int n) :
                n_(n), precursor_(0)
        {
        }
        ~Filter()
        {
        }
        void connect(Filter& f)
        {
            precursor_ = &f;
        }
        void run()
        {
            if (!isCalculationDone_) {
                if (precursor_) {
                    boost::thread thread(&Filter::run, precursor_);
                    thread.join();
                }
                this->processQueue(2);
                isCalculationDone_ = true;
            }
        }
        void processQueue(unsigned N)
        {
            //do some calculations
        }
    public:
        int n_;
        Filter* precursor_;
        bool isCalculationDone_;
};
int main(int argc, char* argv[])
{
    Filter* f1 = new Filter(1);
    Filter* f2 = new Filter(2);
    f2->connect(*f1);
    f2->run();
    std::cerr << "main: done" << std::endl;
    delete f2;
    delete f1;
    return 0;
}
;