多线程 - C++11 std::thread这么使用为什么不对？

问题描述

问 题

我写了这么一段代码，是想用B包裹一个线程，然后方便做一些操作，和关联一些变量。

class B
{
public:
    B(std::thread* a):t(a)
    {}
    static void run(B* s)
    {
        while(s->done)
        {
            //do something
        }
    }
private:
    bool done/*=false*/;
    std::thread* t;
};
class A
{
    A():
    a(new std::thread(&B::run,&a)),
    b(new std::thread(&B::run,&b)),
    c(new std::thread(&B::run,&c)),
    d(new std::thread(&B::run,&d))
    {}
private:
    B a;
    B b;
    B c;
    B d;
};

然后在VS2015下就出事了，函数B::run()传入的参数指针s的内容都是0xcdcdcdcd。但是看了一下，参数s的地址和申请时候的地址却是一样的，在主线程也查了一下这个地址发现却是有内容的，请问这是怎么回事呢？
或者说我的使用方法有误？正确的方法是什么样子的呢？

============

原本的问题是这样的，我有一个程序要在一个阶段要产生大量的片元数据来进行类似的插值计算，这些计算原本是在单线程的，后来发现消耗太高想把这些任务分给几个线程，让这些线程来完成这些任务，最后把结果合并起来。
我想的是给每个线程都搞了一个单生产者单消费者队列，主线程不断地根据负载把片元往这些线程里面装，线程不断消化，然后在一个指定的地方同步。
大概代码是这样的：
上面那个B是我用来包裹线程的类，我的思路是把队列和一些其他和这个线程相关的操作（同步、写入计算数据，写入计算终结信号等等）都封装到一起，然后程序开始的时候创建四个B对象，让这四个线程都跑起来，然后主线程可以调用B的方法不断地往线程中写入数据，最后可以使用同步操作来同步四个线程和主线程。
B::run就是我的执行函数。A类相当于是主线程初始化的类。

解决方案

因为在构造函数中传递了this指针

这篇关于多线程 - C++11 std::thread这么使用为什么不对？的文章就介绍到这了，希望我们推荐的答案对大家有所帮助，也希望大家多多支持IT屋！