Завершение работы многопоточного приложения путем установки обработчика сигнала

В следующем коде я создаю игрушечный класс, у которого есть поток, который пишет в очередь, в то время как другой поток читает из этой очереди и печатает его в stdout, Теперь, чтобы полностью завершить работу системы, я установил обработчик для SIGINT, Я ожидаю, что обработчик сигнала настроит std::atomic<bool> переменная stopFlag, что приведет threadB протолкнуть ядовитую таблетку (страж) в очередь, threadA остановится

class TestClass
{
public:

TestClass();
~TestClass();
void shutDown();

TestClass(const TestClass&) = delete;
TestClass& operator=(const TestClass&) = delete;private:
void init();
void postResults();
std::string getResult();
void processResults();

std::atomic<bool> stopFlag;

std::mutex outQueueMutex;
std::condition_variable outQueueConditionVariable;
std::queue<std::string> outQueue;

std::unique_ptr<std::thread> threadA;
std::unique_ptr<std::thread> threadB;
};

void TestClass::init()
{
threadA = std::make_unique<std::thread>(&TestClass::processResults, std::ref(*this));
threadB = std::make_unique<std::thread>(&TestClass::postResults, std::ref(*this));
}

TestClass::TestClass():
stopFlag(false)
{
init();
}

TestClass::~TestClass()
{
threadB->join();
}

void TestClass::postResults()
{
while(true)
{
std::this_thread::sleep_for(std::chrono::milliseconds(2000));
std::string name = "ABCDEF";
{
std::unique_lock<std::mutex> lock(outQueueMutex);
outQueue.push(name);
outQueueConditionVariable.notify_one();
}
if(stopFlag)
{
/*For shutting down output thread*/
auto poisonPill = std::string();
{
std::unique_lock<std::mutex> lock(outQueueMutex);
outQueue.push(poisonPill);
outQueueConditionVariable.notify_one();
}
threadA->join();
break;
}
}
}

void TestClass::shutDown()
{
stopFlag = true;
}

std::string TestClass::getResult()
{
std::string result;
{
std::unique_lock<std::mutex> lock(outQueueMutex);
while(outQueue.empty())
{
outQueueConditionVariable.wait(lock);
}
result= outQueue.front();
outQueue.pop();
}
return result;
}

void TestClass::processResults()
{
while(true)
{
const auto result = getResult();

if(result.empty())
{
break;
}

std::cout << result << std::endl;

}
}

static void sigIntHandler(std::shared_ptr<TestClass> t, int)
{
t->shutDown();
}
static std::function<void(int)> handler;

int main()
{
auto testClass = std::make_shared<TestClass>();
handler = std::bind(sigIntHandler, testClass, std::placeholders::_1);
std::signal(SIGINT, [](int n){ handler(n);});
return 0;
}

Я скомпилировал это, используя gcc 5.2, используя флаг -std = c ++ 14. При нажатии Ctrl-C на моем компьютере с CentOS 7 я получаю следующую ошибку:

terminate called after throwing an instance of 'std::system_error'
what():  Invalid argument
Aborted (core dumped)

Пожалуйста, помогите мне понять, что происходит.