X-Git-Url: http://git.tdb.fi/?p=libs%2Fcore.git;a=blobdiff_plain;f=source%2Fcore%2Fthread.cpp;h=6c542e6a6712d4e19323fbd779c401abd7ea4215;hp=cfc0c37573d02a100df148a433a0bf365b76111f;hb=a23176e6d3399bbeb75cf6a173543bf5d5f85187;hpb=89c8388a629433b54b7f0cd128b79e308f7d0555 diff --git a/source/core/thread.cpp b/source/core/thread.cpp index cfc0c37..6c542e6 100644 --- a/source/core/thread.cpp +++ b/source/core/thread.cpp @@ -4,8 +4,11 @@ #include #include #endif +#include #include "thread.h" +using namespace std; + namespace Msp { struct Thread::Private @@ -19,33 +22,35 @@ struct Thread::Private Private(): handle(0) { } #ifdef WIN32 - static DWORD WINAPI main_wrapper(void *t) - { reinterpret_cast(t)->main(); return 0; } + static DWORD WINAPI #else - static void *main_wrapper(void *t) - { reinterpret_cast(t)->main(); return 0; } + static void * #endif + main_wrapper(void *a) + { + Thread *t = reinterpret_cast(a); + t->main(); + t->state_ = FINISHED; + return 0; + } }; Thread::Thread(): priv_(new Private), - launched_(false) + state_(PENDING) { } Thread::~Thread() { - if(launched_) - { - kill(); - join(); - } + kill(); + join(); delete priv_; } void Thread::join() { - if(!launched_) + if(state_>=JOINED) return; #ifdef WIN32 @@ -53,22 +58,26 @@ void Thread::join() #else pthread_join(priv_->handle, 0); #endif - launched_ = false; + state_ = JOINED; } void Thread::kill() { + if(state_!=RUNNING) + return; + #ifdef WIN32 TerminateThread(priv_->handle, 0); #else pthread_kill(priv_->handle, SIGKILL); #endif + state_ = KILLED; } void Thread::launch() { - if(launched_) - return; + if(state_>=RUNNING) + throw logic_error("already launched"); #ifdef WIN32 DWORD dummy; // Win9x needs the lpTthreadId parameter @@ -76,7 +85,7 @@ void Thread::launch() #else pthread_create(&priv_->handle, 0, &Private::main_wrapper, this); #endif - launched_ = true; + state_ = RUNNING; } } // namespace Msp