X-Git-Url: http://git.tdb.fi/?a=blobdiff_plain;f=source%2Fthread.h;h=2b0766c68ba7fbd0d443265d30d58628ddda76f8;hb=ee0f34083d99c81ac1393bc1fddadfdadb201a38;hp=a115853211ba122ddb3628326339d43473474a0b;hpb=1013e3c216cdf8e0ecc0f3b1e8314989b5333818;p=libs%2Fcore.git diff --git a/source/thread.h b/source/thread.h index a115853..2b0766c 100644 --- a/source/thread.h +++ b/source/thread.h @@ -6,28 +6,43 @@ Distributed under the LGPL #ifndef MSP_FRAMEWORK_THREAD_H_ #define MSP_FRAMEWORK_THREAD_H_ -#include +#include "types.h" namespace Msp { +/** +Base class for threads. To create a thread for some task, derive it from this +class and implement the main() function. Note that threads are not +automatically started upon creation - you must manually call launch() instead. +This is to allow initializing variables of the derived class before the thread +is started. +*/ class Thread { public: - void *join(); - void kill(int s) { pthread_kill(thread_, s); } + void join(); + void cancel(); + void kill(); virtual ~Thread(); protected: - Thread() { } - void launch() { pthread_create(&thread_, 0, &main_, this); } - virtual void *main()=0; - void exit(void *r) { pthread_exit(r); } + Thread(): launched_(false) { } + void launch(); + virtual void main()=0; + void check_cancel(); private: - pthread_t thread_; + ThreadHandle thread_; + bool launched_; Thread(const Thread &); Thread &operator=(const Thread &); - static void *main_(void *t) { return ((Thread *)t)->main(); } +#ifdef WIN32 +# define THREAD_RETURN_ DWORD WINAPI +#else +# define THREAD_RETURN_ void * +#endif + static THREAD_RETURN_ main_(void *t) { ((Thread *)t)->main(); return 0; } +#undef THREAD_RETURN_ }; } // namespace Msp