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