Back to index

libsfml  1.6+dfsg2
Thread.cpp
Go to the documentation of this file.
00001 
00002 //
00003 // SFML - Simple and Fast Multimedia Library
00004 // Copyright (C) 2007 Laurent Gomila (laurent.gom@gmail.com)
00005 //
00006 // This software is provided 'as-is', without any express or implied warranty.
00007 // In no event will the authors be held liable for any damages arising from the use of this software.
00008 //
00009 // Permission is granted to anyone to use this software for any purpose,
00010 // including commercial applications, and to alter it and redistribute it freely,
00011 // subject to the following restrictions:
00012 //
00013 // 1. The origin of this software must not be misrepresented;
00014 //    you must not claim that you wrote the original software.
00015 //    If you use this software in a product, an acknowledgment
00016 //    in the product documentation would be appreciated but is not required.
00017 //
00018 // 2. Altered source versions must be plainly marked as such,
00019 //    and must not be misrepresented as being the original software.
00020 //
00021 // 3. This notice may not be removed or altered from any source distribution.
00022 //
00024 
00026 // Headers
00028 #include <SFML/System/Unix/Thread.hpp>
00029 #include <iostream>
00030 
00031 
00032 namespace sf
00033 {
00037 Thread::Thread() :
00038 myIsActive(false),
00039 myFunction(NULL),
00040 myUserData(NULL)
00041 {
00042 
00043 }
00044 
00045 
00049 Thread::Thread(Thread::FuncType Function, void* UserData) :
00050 myIsActive(false),
00051 myFunction(Function),
00052 myUserData(UserData)
00053 {
00054 
00055 }
00056 
00057 
00061 Thread::~Thread()
00062 {
00063     // Wait for the thread to finish before destroying the instance
00064     Wait();
00065 }
00066 
00067 
00071 void Thread::Launch()
00072 {
00073     // Wait for the thread to finish, in case it was already running
00074     Wait();
00075 
00076     // Create the thread
00077     myIsActive = true;
00078     int Error = pthread_create(&myThread, NULL, &Thread::ThreadFunc, this);
00079 
00080     // Error ?
00081     if (Error != 0)
00082     {
00083         std::cerr << "Failed to create thread" << std::endl;
00084         myIsActive = false;
00085     }
00086 }
00087 
00088 
00092 void Thread::Wait()
00093 {
00094     if (myIsActive)
00095     {
00096         // Wait for the thread to finish, no timeout
00097         pthread_join(myThread, NULL);
00098 
00099         // Reset the thread state
00100         myIsActive = false;
00101     }
00102 }
00103 
00104 
00111 void Thread::Terminate()
00112 {
00113     if (myIsActive)
00114     {
00115         pthread_cancel(myThread);
00116         myIsActive = false;
00117     }
00118 }
00119 
00120 
00124 void Thread::Run()
00125 {
00126     if (myFunction)
00127         myFunction(myUserData);
00128 }
00129 
00130 
00134 void* Thread::ThreadFunc(void* UserData)
00135 {
00136     // The sfThread instance is stored in the user data
00137     Thread* ThreadToRun = reinterpret_cast<Thread*>(UserData);
00138 
00139     // Tell the thread to handle cancel requests immediatly
00140     pthread_setcanceltype(PTHREAD_CANCEL_ASYNCHRONOUS, NULL);
00141 
00142     // Forward to the instance
00143     ThreadToRun->Run();
00144 
00145     return NULL;
00146 }
00147 
00148 } // namespace sf