使用 boost::thread(英语:Actor） 计算模型

我正在尝试使用 boost：：thread 在C++上的线程上实现 Actor 计算模型。但是程序在执行过程中会抛出奇怪的异常。异常不稳定，有时程序以正确的方式工作。

那里我的代码：

演员.hpp

class Actor {
  public:
    typedef boost::function<int()> Job;
  private:
    std::queue<Job>             d_jobQueue;
    boost::mutex                d_jobQueueMutex;
    boost::condition_variable   d_hasJob;
    boost::atomic<bool>         d_keepWorkerRunning;
    boost::thread               d_worker;
    void workerThread();
  public:
    Actor();
    virtual ~Actor();
    void execJobAsync(const Job& job);
    int execJobSync(const Job& job);
};

演员.cpp

namespace {
int executeJobSync(std::string          *error,
                   boost::promise<int> *promise,
                   const Actor::Job     *job)
{
    int rc = (*job)();
    promise->set_value(rc);
    return 0;
}
}
void Actor::workerThread()
{
    while (d_keepWorkerRunning) try {
        Job job;
        {
            boost::unique_lock<boost::mutex> g(d_jobQueueMutex);
            while (d_jobQueue.empty()) {
                d_hasJob.wait(g);
            }
            job = d_jobQueue.front();
            d_jobQueue.pop();
        }
        job();
    }
    catch (...) {
        // Log error
    }
}
void Actor::execJobAsync(const Job& job)
{
    boost::mutex::scoped_lock g(d_jobQueueMutex);
    d_jobQueue.push(job);
    d_hasJob.notify_one();
}
int Actor::execJobSync(const Job& job)
{
    std::string error;
    boost::promise<int> promise;
    boost::unique_future<int> future = promise.get_future();
    {
        boost::mutex::scoped_lock g(d_jobQueueMutex);
        d_jobQueue.push(boost::bind(executeJobSync, &error, &promise, &job));
        d_hasJob.notify_one();
    }
    int rc = future.get();
    if (rc) {
        ErrorUtil::setLastError(rc, error.c_str());
    }
    return rc;
}
Actor::Actor()
: d_keepWorkerRunning(true)
, d_worker(&Actor::workerThread, this)
{
}
Actor::~Actor()
{
    d_keepWorkerRunning = false;
    {
        boost::mutex::scoped_lock g(d_jobQueueMutex);
        d_hasJob.notify_one();
    }
    d_worker.join();
}

实际上，抛出的异常是 boost：：thread_interrupted 在int rc = future.get();行中。但是表单提升文档我无法推理此异常。文档 说

抛出： - boost：：thread_interrupted 如果与 *this 关联的结果在调用时尚未准备就绪，并且当前线程被中断。

但是我的工作线程不能处于中断状态。

当我使用 gdb 并设置"捕获抛出"时，我看到回跟踪看起来像

扔thread_interrupted

提升：:d尾：：interruption_checker：：check_for_interruption

提升：:d尾：：interruption_checker：：interruption_checker

提升：：condition_variable：：等待

提升：:d尾：：future_object_base：：wait_internal

提升：:d尾部：：future_object_base：：等待

提升：:d尾部：：future_object：：获取

提升：：unique_future：：获取

我查看了提升源，但不明白为什么interruption_checker决定工作线程中断。

所以有人C++上师，请帮助我。我需要做什么才能获得正确的代码？我正在使用：

助推器 1_53

Linux 版本 2.6.18-194.32.1.el5 Red Hat 4.1.2-48

海湾合作委员会 4.7

编辑

修好了！感谢叶夫根尼·帕纳修克和拉津。问题出在 TLS 中 管理。boost：：线程和 boost：：thread_specific_ptr正在使用 用于其目的的相同 TLS 存储。就我而言，当 他们都试图在创建时更改此存储（不幸的是，我 不明白为什么会详细发生）。所以TLS被破坏了。

我用__thread替换了代码中的 boost：：thread_specific_ptr 指定的变量。

Offtop：在调试期间，我发现外部库中的内存损坏 并修复了它=）

.

编辑 2 我遇到了确切的问题...这是 GCC 中的一个错误 =） _GLIBCXX_DEBUG编译标志会中断 ABI。 您可以看到有关boost错误跟踪器的讨论： https://svn.boost.org/trac/boost/ticket/7666