TimeBomb.cpp

#include <iostream>
#include "TimeBomb.hpp"
#include <boost/date_time/posix_time/posix_time.hpp>

using namespace std;
using namespace boost;
using namespace boost::python;

void ITimeBombCallbackWrapper::ReceiveExplosion()
{
    // Yeap, getting the GIL.
    PyGILState_STATE gstate = PyGILState_Ensure();
    this->get_override("ReceiveExplosion")();
    PyGILState_Release(gstate);
}

TimeBomb::TimeBomb(ITimeBombCallback* luckyWinner)
{
    this->luckyWinner = luckyWinner;
    backgroundThread = NULL;
}

void TimeBomb::Go()
{
    backgroundThread = new boost::thread(boost::bind(&TimeBomb::InnerBody, this));
}

void TimeBomb::InnerBody()
{
    cout << "Inside the inner body of the time bomb." << endl;

    // We'll just do some donuts in the parking lot here while we wait for 5 seconds
    boost::this_thread::sleep(boost::posix_time::seconds(5));

    cout << "Five seconds are up.  Time to deliver payload." << endl;

    // Original callback that started this whole mess was firing off quite a few in a short duration,
    // so that's why we repeat the call in such close succession.
    // Indeed, the first call often survives.
    for(int i = 0; i < 5; ++i)
    {
        luckyWinner->ReceiveExplosion();
    }

    cout << "Payload delivered." << endl;
}

void TimeBomb::Join()
{
    if(backgroundThread != NULL)
    {
        backgroundThread->join();
    }
}