文件监控

w1146869587

2021-11-05 cbf39419a8299e7d119618e5e8e1b1eb35f72f45

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
61
62
63
64
65
66
67
68
#include <efsw/platform/posix/ThreadImpl.hpp>
#include <efsw/Thread.hpp>
 
#if defined( EFSW_PLATFORM_POSIX )
 
#include <cassert>
#include <iostream>
#include <efsw/Debug.hpp>
 
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;
}
 
}}
 
#endif