blob: e0ae84fe206968c9e555e71cd55cb43a388c7fe4 (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
|
#include <efsw/Thread.hpp>
#include <efsw/platform/posix/ThreadImpl.hpp>
#if defined( EFSW_PLATFORM_POSIX )
#include <cassert>
#include <efsw/Debug.hpp>
#include <iostream>
namespace efsw { namespace Platform {
ThreadImpl::ThreadImpl( Thread* owner ) : mIsActive( false ) {
mIsActive = pthread_create( &mThread, NULL, &ThreadImpl::entryPoint, owner ) == 0;
if ( !mIsActive ) {
efDEBUG( "Failed to create thread\n" );
}
}
void ThreadImpl::wait() {
// Wait for the thread to finish, no timeout
if ( mIsActive ) {
assert( pthread_equal( pthread_self(), mThread ) == 0 );
pthread_join( mThread, NULL );
mIsActive = false; // Reset the thread state
}
}
void ThreadImpl::terminate() {
if ( mIsActive ) {
#if !defined( __ANDROID__ ) && !defined( ANDROID )
pthread_cancel( mThread );
#else
pthread_kill( mThread, SIGUSR1 );
#endif
mIsActive = false;
}
}
void* ThreadImpl::entryPoint( void* userData ) {
// The Thread instance is stored in the user data
Thread* owner = static_cast<Thread*>( userData );
// Tell the thread to handle cancel requests immediatly
#ifdef PTHREAD_CANCEL_ASYNCHRONOUS
pthread_setcanceltype( PTHREAD_CANCEL_ASYNCHRONOUS, NULL );
#endif
// Forward to the owner
owner->run();
return NULL;
}
}} // namespace efsw::Platform
#endif
|
