#include <boost/thread.hpp>
#include <boost/signals2.hpp>

const int max = 20;
class Base;

typedef boost::signals2::signal<void (Base *)> Signal;

class Base
{
public:
	Base(Signal &sig) : m_sig(sig)
	{
		m_sig.connect(this);
	}

	// Signal function
	void operator() (Base *pCaller)
	{
		if (pCaller != this)
			std::cout << "Oh shit! We've been beaten!" << std::endl;
	}

protected:
	Signal &m_sig;
};


class Countup : Base
{
public:
	Countup(Signal &sig) : Base(sig)
	{ }

	void operator() ()
	{
		int x = 0;

		while (x < max)
		{
			x++;
			std::cout << "Counting up: " << x << std::endl;
			boost::this_thread::sleep(boost::posix_time::milliseconds(750));
		}
		
		m_sig(this);
	}
};

class Countdown : Base
{
public:
	Countdown(Signal &sig) : Base(sig)
	{
	}

	void operator() ()
	{
		int x = max;
		while (x > 0)
		{
			x--;
			std::cout << "Counting down: " << x << std::endl;
			boost::this_thread::sleep(boost::posix_time::milliseconds(1000));
		}

		m_sig(this);
	}
};

int main()
{
	Signal sig;
	boost::thread t1(Countup(sig)), t2(Countdown(sig));

	t1.join();
	t2.join();

	return 0;
}