/// Copyright (c) 2010 Ruben Penalva. All rights reserved.
/// Redistribution and use in source and binary forms, with or without modification, 
/// are permitted provided that the following conditions are met:
///    1. Redistributions of source code must retain the above copyright notice, this 
///    list of conditions and the following disclaimer.
///    2. Redistributions in binary form must reproduce the above copyright notice,
///    this list of conditions and the following disclaimer in the documentation and/or
///    other materials provided with the distribution.
///    3. The name of the author may not be used to endorse or promote products derived
///    from this software without specific prior written permission.
///
/// THIS SOFTWARE IS PROVIDED BY THE AUTHOR ``AS IS'' AND ANY EXPRESS OR IMPLIED WARRANTIES,
/// INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR 
/// A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR ANY DIRECT, 
/// INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED 
/// TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS 
/// INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT 
/// LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF 
/// THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.

#ifndef _THREAD_H_
#define _THREAD_H_

#include <boost\thread.hpp>
#include <boost\shared_ptr.hpp>

#include "IThreadCallable.h"

#include "Timer.h"

namespace TestFrameWork
{

class IThreadCallable;

class Thread
{
public:
	Thread(IThreadCallablePtr threadCallable, boost::barrier& preSetupBarrier, 
		   boost::barrier& postSetupBarrier, int elapsedTimeSamplesCount = 10);

	~Thread(void);
	
	void operator()(void);

	void Join(void);

	void Stop(void);

	float MeanElapsedTime(void) const;

private:
	Timer m_timer;

	IThreadCallablePtr m_callable;

	bool m_stop;

	boost::shared_ptr<boost::thread> m_thread;

	bool m_waitForInit;

	boost::barrier m_initBarrier;

	boost::barrier& m_preSetupBarrier;

	boost::barrier& m_postSetupBarrier;
};

typedef boost::shared_ptr<Thread> ThreadPtr;

}

#endif