WebSVN – HomeAutomation – Diff – /trunk/PcSoftware/Atom/src/Threads/thread.h


/***************************************************************************
 *   Copyright (C) November 29, 2008 by Mattias Runge                             *
 *   mattias@runge.se                                                      *
 *   thread.h                                            *
 *                                                                         *
 *   This program is free software; you can redistribute it and/or modify  *
 *   it under the terms of the GNU General Public License as published by  *
 *   the Free Software Foundation; either version 2 of the License, or     *
 *   (at your option) any later version.                                   *
 *                                                                         *
 *   This program is distributed in the hope that it will be useful,       *
 *   but WITHOUT ANY WARRANTY; without even the implied warranty of        *
 *   MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the         *
 *   GNU General Public License for more details.                          *
 *                                                                         *
 *   You should have received a copy of the GNU General Public License     *
 *   along with this program; if not, write to the                         *
 *   Free Software Foundation, Inc.,                                       *
 *   59 Temple Place - Suite 330, Boston, MA  02111-1307, USA.             *
 ***************************************************************************/
 
#ifndef _THREAD_H
#define _THREAD_H
 
#include <pthread.h>
#include <iostream>
 
template <class T>
class Thread
{
public:
    Thread()
    {
        myIsCreated = false;
        myError = 0;
    };
    ~Thread()
    {
        stop();
    };
 
    bool stop()
    {
       
        if (!myIsCreated)
        {
            //cout << "Thread is not running, can not be stopped " << endl;
            return true;
        }
       
        //cout << "Thread cancel to run " << endl;
       
        //myError = pthread_cancel(myHandle);
        myError = pthread_detach(myHandle);
        //cout << "Thread cancel returned " << myError << endl;
       
       
       
        //if (joinThread)
        {
            //join();
        }
       
 
 
        myIsCreated = false;
 
        return myError == 0;
    };
   
    bool start()
    {
        myError = pthread_create(&myHandle, NULL, T::doThread, (void*)this);
       
        if (myError != 0)
        {
            myIsCreated = false;
            return false;
        }
 
        myIsCreated = true;
        return true;
    };
 
    bool join()
    {
        if (!myIsCreated)
            return false;
 
        myError = pthread_join(myHandle, NULL);
 
        if (myError != 0)
        {
            myIsCreated = false;
            return false;
        }
 
        myIsCreated = true;
        return true;
    };
 
    int getError()
    {
        return myError;
    };
 
    static void *doThread(void* ptr)
    {
        ((T*)ptr)->run();
    };
 
    virtual void run() { };
 
private:
    bool myIsCreated;
    pthread_t myHandle;
    int myError;
};
 
#endif  /* _THREAD_H */
 
 

Rev 1026	Rev 1124
1	/***************************************************************************	1	/***************************************************************************
2	* Copyright (C) November 29, 2008 by Mattias Runge *	2	* Copyright (C) November 29, 2008 by Mattias Runge *
3	* mattias@runge.se *	3	* mattias@runge.se *
4	* thread.h *	4	* thread.h *
5	* *	5	* *
6	* This program is free software; you can redistribute it and/or modify *	6	* This program is free software; you can redistribute it and/or modify *
7	* it under the terms of the GNU General Public License as published by *	7	* it under the terms of the GNU General Public License as published by *
8	* the Free Software Foundation; either version 2 of the License, or *	8	* the Free Software Foundation; either version 2 of the License, or *
9	* (at your option) any later version. *	9	* (at your option) any later version. *
10	* *	10	* *
11	* This program is distributed in the hope that it will be useful, *	11	* This program is distributed in the hope that it will be useful, *
12	* but WITHOUT ANY WARRANTY; without even the implied warranty of *	12	* but WITHOUT ANY WARRANTY; without even the implied warranty of *
13	* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the *	13	* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the *
14	* GNU General Public License for more details. *	14	* GNU General Public License for more details. *
15	* *	15	* *
16	* You should have received a copy of the GNU General Public License *	16	* You should have received a copy of the GNU General Public License *
17	* along with this program; if not, write to the *	17	* along with this program; if not, write to the *
18	* Free Software Foundation, Inc., *	18	* Free Software Foundation, Inc., *
19	* 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA. *	19	* 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA. *
20	***************************************************************************/	20	***************************************************************************/
21		21
22	#ifndef _THREAD_H	22	#ifndef _THREAD_H
23	#define _THREAD_H	23	#define _THREAD_H
24		24
25	#include <pthread.h>	25	#include <pthread.h>
-		26	#include <iostream>
26		27
27	template <class T>	28	template <class T>
28	class Thread	29	class Thread
29	{	30	{
30	public:	31	public:
31	Thread()	32	Thread()
32	{	33	{
33	myIsCreated = false;	34	myIsCreated = false;
34	myError = 0;	35	myError = 0;
35	};	36	};
36	~Thread()	37	~Thread()
37	{	38	{
38	stop();	39	stop();
39	};	40	};
40		41
41	bool stop()	42	bool stop()
42	{	43	{
-		44
43	if (!myIsCreated)	45	if (!myIsCreated)
-		46	{
-		47	//cout << "Thread is not running, can not be stopped " << endl;
44	return true;	48	return true;
-		49	}
-		50
-		51	//cout << "Thread cancel to run " << endl;
-		52
-		53	//myError = pthread_cancel(myHandle);
-		54	myError = pthread_detach(myHandle);
-		55	//cout << "Thread cancel returned " << myError << endl;
-		56
-		57
-		58
-		59	//if (joinThread)
-		60	{
-		61	//join();
-		62	}
45		63
46	myError = pthread_cancel(myHandle);	-
47	join();	-
48	myIsCreated = false;	64	myIsCreated = false;
49		65
50	return myError == 0;	66	return myError == 0;
51	};	67	};
52		68
53	bool start()	69	bool start()
54	{	70	{
55	myError = pthread_create(&myHandle, NULL, T::doThread, (void*)this);	71	myError = pthread_create(&myHandle, NULL, T::doThread, (void*)this);
56		72
57	if (myError != 0)	73	if (myError != 0)
58	{	74	{
59	myIsCreated = false;	75	myIsCreated = false;
60	return false;	76	return false;
61	}	77	}
62		78
63	myIsCreated = true;	79	myIsCreated = true;
64	return true;	80	return true;
65	};	81	};
66		82
67	bool join()	83	bool join()
68	{	84	{
69	if (!myIsCreated)	85	if (!myIsCreated)
70	return false;	86	return false;
71		87
72	myError = pthread_join(myHandle, NULL);	88	myError = pthread_join(myHandle, NULL);
73		89
74	if (myError != 0)	90	if (myError != 0)
75	{	91	{
76	myIsCreated = false;	92	myIsCreated = false;
77	return false;	93	return false;
78	}	94	}
79		95
80	myIsCreated = true;	96	myIsCreated = true;
81	return true;	97	return true;
82	};	98	};
83		99
84	int getError()	100	int getError()
85	{	101	{
86	return myError;	102	return myError;
87	};	103	};
88		104
89	static void doThread(void ptr)	105	static void doThread(void ptr)
90	{	106	{
91	((T*)ptr)->run();	107	((T*)ptr)->run();
92	};	108	};
93		109
94	virtual void run() { };	110	virtual void run() { };
95		111
96	private:	112	private:
97	bool myIsCreated;	113	bool myIsCreated;
98	pthread_t myHandle;	114	pthread_t myHandle;
99	int myError;	115	int myError;
100	};	116	};
101		117
102	#endif /* _THREAD_H */	118	#endif /* _THREAD_H */
103		119
104		120

Subversion Repositories HomeAutomation

(root)/trunk/PcSoftware/Atom/src/Threads/thread.h – Rev 1026 → 1124