xref: /trunk/main/cppu/source/threadpool/thread.hxx (revision cdf0e10c)
1 /*************************************************************************
2  *
3  * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER.
4  *
5  * Copyright 2000, 2010 Oracle and/or its affiliates.
6  *
7  * OpenOffice.org - a multi-platform office productivity suite
8  *
9  * This file is part of OpenOffice.org.
10  *
11  * OpenOffice.org is free software: you can redistribute it and/or modify
12  * it under the terms of the GNU Lesser General Public License version 3
13  * only, as published by the Free Software Foundation.
14  *
15  * OpenOffice.org is distributed in the hope that it will be useful,
16  * but WITHOUT ANY WARRANTY; without even the implied warranty of
17  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
18  * GNU Lesser General Public License version 3 for more details
19  * (a copy is included in the LICENSE file that accompanied this code).
20  *
21  * You should have received a copy of the GNU Lesser General Public License
22  * version 3 along with OpenOffice.org.  If not, see
23  * <http://www.openoffice.org/license.html>
24  * for a copy of the LGPLv3 License.
25  *
26  ************************************************************************/
27 #ifndef _CPPU_THREADPOOL_THREAD_HXX
28 #define _CPPU_THREADPOOL_THREAD_HXX
29 
30 #include <list>
31 #include <sal/types.h>
32 
33 #include <osl/thread.h>
34 
35 #include "jobqueue.hxx"
36 
37 namespace cppu_threadpool {
38 
39 	class JobQueue;
40 	class ThreadAdmin;
41 	typedef boost::shared_ptr<ThreadAdmin> ThreadAdminHolder;
42 
43     //-----------------------------------------
44     // private thread class for the threadpool
45     // independent from vos
46     //-----------------------------------------
47 	class ORequestThread
48 	{
49 	public:
50 		ORequestThread( JobQueue * ,
51 						const ::rtl::ByteSequence &aThreadId,
52 						sal_Bool bAsynchron );
53 		~ORequestThread();
54 
55 		void setTask( JobQueue * , const ::rtl::ByteSequence & aThreadId , sal_Bool bAsynchron );
56 
57 		sal_Bool create();
58 		void join();
59 		void onTerminated();
60 		void run();
61 		inline void setDeleteSelf( sal_Bool b )
62 			{ m_bDeleteSelf = b; }
63 
64 	private:
65 		oslThread m_thread;
66 		ThreadAdminHolder m_aThreadAdmin;
67 		JobQueue *m_pQueue;
68 		::rtl::ByteSequence m_aThreadId;
69 		sal_Bool m_bAsynchron;
70 		sal_Bool m_bDeleteSelf;
71 	};
72 
73 	class ThreadAdmin
74 	{
75 	public:
76 		~ThreadAdmin ();
77 		static ThreadAdminHolder &getInstance();
78 		void add( ORequestThread * );
79 		void remove( ORequestThread * );
80 		void join();
81 
82 	private:
83 		::osl::Mutex m_mutex;
84 		::std::list< ORequestThread * > m_lst;
85 	};
86 
87 } // end cppu_threadpool
88 
89 
90 #endif
91 
92