+
+ /** This is called by the default destructor of the Thread
+ * class to ensure that the thread engine which created the thread
+ * is responsible for destroying it.
+ * @param thread Existing and active thread to delete.
+ */
+ virtual void FreeThread(Thread* thread) = 0;
+
+ /** Returns the thread engine's name for display purposes
+ * @return The thread engine name
+ */
+ virtual const std::string GetName()
+ {
+ return "<pure-virtual>";
+ }
+};
+
+/** The Mutex class represents a mutex, which can be used to keep threads
+ * properly synchronised. Use mutexes sparingly, as they are a good source
+ * of thread deadlocks etc, and should be avoided except where absolutely
+ * neccessary. Note that the internal behaviour of the mutex varies from OS
+ * to OS depending on the thread engine, for example in windows a Mutex
+ * in InspIRCd uses critical sections, as they are faster and simpler to
+ * manage.
+ */
+class CoreExport Mutex : public Extensible
+{
+ protected:
+
+ /** Creator object
+ */
+ InspIRCd* ServerInstance;
+
+ /** Enable or disable the Mutex. This method has somewhat confusing
+ * wording (e.g. the function name and parameters) so it is protected
+ * in preference of the Lock() and Unlock() methods which are user-
+ * accessible.
+ *
+ * @param enable True to enable the mutex (enter it) and false to
+ * disable the mutex (leave it).
+ */
+ virtual void Enable(bool enable) = 0;
+ public:
+
+ /** Constructor.
+ * @param Instance Creator object
+ */
+ Mutex(InspIRCd* Instance);
+
+ /** Enter/enable the mutex lock.
+ */
+ void Lock() { Enable(true); }
+
+ /** Leave/disable the mutex lock.
+ */
+ void Unlock() { Enable(false); }
+
+ /** Destructor
+ */
+ ~Mutex() { }
+};
+
+/** Derive from this class to implement your own threaded sections of
+ * code. Be sure to keep your code thread-safe and not prone to deadlocks
+ * and race conditions if you MUST use threading!
+ */
+class CoreExport Thread : public Extensible
+{
+ private:
+ /** Set to true when the thread is to exit
+ */
+ bool ExitFlag;
+ public:
+
+ /** Creator thread engine
+ */
+ ThreadEngine* Creator;
+
+ /** Set Creator to NULL at this point
+ */
+ Thread() : ExitFlag(false), Creator(NULL)
+ {
+ }
+
+ /** If this thread has a Creator set, call it to
+ * free the thread
+ */
+ virtual ~Thread()
+ {
+ if (Creator)
+ Creator->FreeThread(this);
+ }
+
+ /** Override this method to put your actual
+ * threaded code here.
+ */
+ virtual void Run() = 0;
+
+ /** Signal the thread to exit gracefully.
+ */
+ void SetExitFlag()
+ {
+ ExitFlag = true;
+ }
+
+ /** Cancel an exit state.
+ */
+ void ClearExitFlag()
+ {
+ ExitFlag = false;
+ }
+
+ /** Get thread's current exit status.
+ * (are we being asked to exit?)
+ */
+ bool GetExitFlag()
+ {
+ return ExitFlag;
+ }