1*c6ed87c9SAndrew Rist /************************************************************** 2cdf0e10cSrcweir * 3*c6ed87c9SAndrew Rist * Licensed to the Apache Software Foundation (ASF) under one 4*c6ed87c9SAndrew Rist * or more contributor license agreements. See the NOTICE file 5*c6ed87c9SAndrew Rist * distributed with this work for additional information 6*c6ed87c9SAndrew Rist * regarding copyright ownership. The ASF licenses this file 7*c6ed87c9SAndrew Rist * to you under the Apache License, Version 2.0 (the 8*c6ed87c9SAndrew Rist * "License"); you may not use this file except in compliance 9*c6ed87c9SAndrew Rist * with the License. You may obtain a copy of the License at 10*c6ed87c9SAndrew Rist * 11*c6ed87c9SAndrew Rist * http://www.apache.org/licenses/LICENSE-2.0 12*c6ed87c9SAndrew Rist * 13*c6ed87c9SAndrew Rist * Unless required by applicable law or agreed to in writing, 14*c6ed87c9SAndrew Rist * software distributed under the License is distributed on an 15*c6ed87c9SAndrew Rist * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY 16*c6ed87c9SAndrew Rist * KIND, either express or implied. See the License for the 17*c6ed87c9SAndrew Rist * specific language governing permissions and limitations 18*c6ed87c9SAndrew Rist * under the License. 19*c6ed87c9SAndrew Rist * 20*c6ed87c9SAndrew Rist *************************************************************/ 21*c6ed87c9SAndrew Rist 22*c6ed87c9SAndrew Rist 23cdf0e10cSrcweir 24cdf0e10cSrcweir #ifndef _CPPU_THREADPOOL_JOBQUEUE_HXX_ 25cdf0e10cSrcweir #define _CPPU_THREADPOOL_JOBQUEUE_HXX_ 26cdf0e10cSrcweir 27cdf0e10cSrcweir #include <list> 28cdf0e10cSrcweir #include <sal/types.h> 29cdf0e10cSrcweir 30cdf0e10cSrcweir #include <osl/conditn.h> 31cdf0e10cSrcweir #include <osl/mutex.hxx> 32cdf0e10cSrcweir 33cdf0e10cSrcweir #include <boost/shared_ptr.hpp> 34cdf0e10cSrcweir 35cdf0e10cSrcweir namespace cppu_threadpool 36cdf0e10cSrcweir { 37cdf0e10cSrcweir extern "C" typedef void (SAL_CALL RequestFun)(void *); 38cdf0e10cSrcweir 39cdf0e10cSrcweir struct Job 40cdf0e10cSrcweir { 41cdf0e10cSrcweir void *pThreadSpecificData; 42cdf0e10cSrcweir RequestFun * doRequest; 43cdf0e10cSrcweir }; 44cdf0e10cSrcweir 45cdf0e10cSrcweir typedef ::std::list < struct Job > JobList; 46cdf0e10cSrcweir 47cdf0e10cSrcweir typedef ::std::list < sal_Int64 > CallStackList; 48cdf0e10cSrcweir 49cdf0e10cSrcweir class DisposedCallerAdmin; 50cdf0e10cSrcweir typedef boost::shared_ptr<DisposedCallerAdmin> DisposedCallerAdminHolder; 51cdf0e10cSrcweir 52cdf0e10cSrcweir class JobQueue 53cdf0e10cSrcweir { 54cdf0e10cSrcweir public: 55cdf0e10cSrcweir JobQueue(); 56cdf0e10cSrcweir ~JobQueue(); 57cdf0e10cSrcweir 58cdf0e10cSrcweir void add( void *pThreadSpecificData, RequestFun * doRequest ); 59cdf0e10cSrcweir 60cdf0e10cSrcweir void *enter( sal_Int64 nDisposeId , sal_Bool bReturnWhenNoJob = sal_False ); 61cdf0e10cSrcweir void dispose( sal_Int64 nDisposeId ); 62cdf0e10cSrcweir 63cdf0e10cSrcweir void suspend(); 64cdf0e10cSrcweir void resume(); 65cdf0e10cSrcweir 66cdf0e10cSrcweir sal_Bool isEmpty(); 67cdf0e10cSrcweir sal_Bool isCallstackEmpty(); 68cdf0e10cSrcweir sal_Bool isBusy(); 69cdf0e10cSrcweir 70cdf0e10cSrcweir private: 71cdf0e10cSrcweir ::osl::Mutex m_mutex; 72cdf0e10cSrcweir JobList m_lstJob; 73cdf0e10cSrcweir CallStackList m_lstCallstack; 74cdf0e10cSrcweir sal_Int32 m_nToDo; 75cdf0e10cSrcweir sal_Bool m_bSuspended; 76cdf0e10cSrcweir oslCondition m_cndWait; 77cdf0e10cSrcweir DisposedCallerAdminHolder m_DisposedCallerAdmin; 78cdf0e10cSrcweir }; 79cdf0e10cSrcweir } 80cdf0e10cSrcweir 81cdf0e10cSrcweir #endif 82