Модель расчета актера с использованием boost :: thread

Я пытаюсь реализовать модель вычисления Actor над потоками на C ++, используя boost :: thread.
Но программа выдает странное исключение во время выполнения. Исключение не стабильно, и иногда программа работает правильно.

Там мой код:

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);
};

actor.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, если результат, связанный с *, не готов в момент вызова, и текущий поток прерывается.

Но мой рабочий поток не может быть прерван.

Когда я использовал gdb и установил «catch throw», я вижу, что обратная трассировка выглядит как

бросить thread_interrupted

повышение :: подробнее :: interruption_checker :: check_for_interruption

повышение :: подробнее :: interruption_checker :: interruption_checker

повышение :: condition_variable :: ждать

повышение :: подробнее :: future_object_base :: wait_internal

повышение :: детали :: future_object_base :: ждать

повышение :: детали :: future_object :: получить

повышение :: unique_future :: получить

Я изучил источники повышения, но не могу понять, почему interrupt_checker решил, что рабочий поток прерывается.

Так что кто-то гуру C ++, пожалуйста, помогите мне. Что мне нужно сделать, чтобы получить правильный код?
Я использую:

повысить 1_53

Версия Linux 2.6.18-194.32.1.el5 Red Hat 4.1.2-48

gcc 4.7

РЕДАКТИРОВАТЬ

Починил это! Спасибо Евгению Панасюку и Лазину. Проблема была в TLS
управление. boost :: thread и boost :: thread_specific_ptr используют
такое же хранилище TLS для своих целей. В моем случае была проблема, когда
они оба пытались изменить это хранилище при создании (К сожалению, я
не понимаю, почему в деталях это происходит). Так что TLS испортился.

Я заменил boost :: thread_specific_ptr из моего кода на __thread
указанная переменная.

Оффтоп: во время отладки я обнаружил повреждение памяти во внешней библиотеке
и исправил это =)

.

РЕДАКТИРОВАТЬ 2
У меня есть точная проблема … Это ошибка в GCC =)
Флаг компиляции _GLIBCXX_DEBUG нарушает ABI.
Вы можете увидеть обсуждение багтрекера Boost:
https://svn.boost.org/trac/boost/ticket/7666