summaryrefslogtreecommitdiffstats
path: root/src/OSSupport/IsThread.h
diff options
context:
space:
mode:
authorTiger Wang <ziwei.tiger@outlook.com>2021-03-28 23:33:24 +0200
committerTiger Wang <ziwei.tiger@outlook.com>2021-03-30 00:36:15 +0200
commit222d9957a1a566464d6a824caaf9a56539eb3234 (patch)
treec4bd9041e07a61c6f1a1eaaf70838e26fafae82e /src/OSSupport/IsThread.h
parentDo an early check for empty network buffers (#5172) (diff)
downloadcuberite-222d9957a1a566464d6a824caaf9a56539eb3234.tar
cuberite-222d9957a1a566464d6a824caaf9a56539eb3234.tar.gz
cuberite-222d9957a1a566464d6a824caaf9a56539eb3234.tar.bz2
cuberite-222d9957a1a566464d6a824caaf9a56539eb3234.tar.lz
cuberite-222d9957a1a566464d6a824caaf9a56539eb3234.tar.xz
cuberite-222d9957a1a566464d6a824caaf9a56539eb3234.tar.zst
cuberite-222d9957a1a566464d6a824caaf9a56539eb3234.zip
Diffstat (limited to '')
-rw-r--r--src/OSSupport/IsThread.h45
1 files changed, 21 insertions, 24 deletions
diff --git a/src/OSSupport/IsThread.h b/src/OSSupport/IsThread.h
index 6a515a6de..4c2131d24 100644
--- a/src/OSSupport/IsThread.h
+++ b/src/OSSupport/IsThread.h
@@ -2,11 +2,10 @@
// IsThread.h
// Interfaces to the cIsThread class representing an OS-independent wrapper for a class that implements a thread.
-// This class will eventually suupersede the old cThread class
/*
Usage:
-To have a new thread, declare a class descending from cIsClass.
+To have a new thread, declare a class descending from cIsThread.
Then override its Execute() method to provide your thread processing.
In the descending class' constructor call the Start() method to start the thread once you're finished with initialization.
*/
@@ -23,46 +22,44 @@ In the descending class' constructor call the Start() method to start the thread
class cIsThread
{
-protected:
- /** This is the main thread entrypoint.
- This function, overloaded by the descendants, is called in the new thread. */
- virtual void Execute(void) = 0;
-
- /** The overriden Execute() method should check this value periodically and terminate if this is true. */
- std::atomic<bool> m_ShouldTerminate;
-
public:
+
cIsThread(AString && a_ThreadName);
virtual ~cIsThread();
/** Starts the thread; returns without waiting for the actual start. */
- bool Start(void);
+ void Start(void);
/** Signals the thread to terminate and waits until it's finished. */
void Stop(void);
- /** Waits for the thread to finish. Doesn't signalize the ShouldTerminate flag. */
- bool Wait(void);
-
/** Returns true if the thread calling this function is the thread contained within this object. */
bool IsCurrentThread(void) const { return std::this_thread::get_id() == m_Thread.get_id(); }
-private:
+protected:
- /** The name of the thread, used to aid debugging in IDEs which support named threads */
- AString m_ThreadName;
+ /** This function, overloaded by the descendants, is called in the new thread. */
+ virtual void Execute(void) = 0;
+
+ /** The overriden Execute() method should check this value periodically and terminate if this is true. */
+ std::atomic<bool> m_ShouldTerminate;
+
+private:
/** The thread object which holds the created thread for later manipulation */
std::thread m_Thread;
+ /** The name of the thread, used to aid debugging in IDEs which support named threads */
+ AString m_ThreadName;
+
/** The event that is used to wait with the thread's execution until the thread object is fully initialized.
This prevents the IsCurrentThread() call to fail because of a race-condition where the thread starts before m_Thread has been fully assigned. */
- cEvent m_evtStart;
-
- /** Wrapper for Execute() that waits for the initialization event, to prevent race conditions in thread initialization. */
- void DoExecute(void);
-} ;
-
-
+ cEvent m_Initialisation;
+ /** This is the main thread entrypoint.
+ Wrapper for Execute() that waits for the initialization event, to prevent race conditions in thread initialization. */
+ void Entrypoint(void);
+ /** Sets the name of the current thread to be the name provided in m_ThreadName. */
+ void SetThreadName() const;
+} ;