xref: /trunk/main/cppu/source/threadpool/jobqueue.hxx (revision cdf0e10c)
1*cdf0e10cSrcweir /*************************************************************************
2*cdf0e10cSrcweir  *
3*cdf0e10cSrcweir  * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER.
4*cdf0e10cSrcweir  *
5*cdf0e10cSrcweir  * Copyright 2000, 2010 Oracle and/or its affiliates.
6*cdf0e10cSrcweir  *
7*cdf0e10cSrcweir  * OpenOffice.org - a multi-platform office productivity suite
8*cdf0e10cSrcweir  *
9*cdf0e10cSrcweir  * This file is part of OpenOffice.org.
10*cdf0e10cSrcweir  *
11*cdf0e10cSrcweir  * OpenOffice.org is free software: you can redistribute it and/or modify
12*cdf0e10cSrcweir  * it under the terms of the GNU Lesser General Public License version 3
13*cdf0e10cSrcweir  * only, as published by the Free Software Foundation.
14*cdf0e10cSrcweir  *
15*cdf0e10cSrcweir  * OpenOffice.org is distributed in the hope that it will be useful,
16*cdf0e10cSrcweir  * but WITHOUT ANY WARRANTY; without even the implied warranty of
17*cdf0e10cSrcweir  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
18*cdf0e10cSrcweir  * GNU Lesser General Public License version 3 for more details
19*cdf0e10cSrcweir  * (a copy is included in the LICENSE file that accompanied this code).
20*cdf0e10cSrcweir  *
21*cdf0e10cSrcweir  * You should have received a copy of the GNU Lesser General Public License
22*cdf0e10cSrcweir  * version 3 along with OpenOffice.org.  If not, see
23*cdf0e10cSrcweir  * <http://www.openoffice.org/license.html>
24*cdf0e10cSrcweir  * for a copy of the LGPLv3 License.
25*cdf0e10cSrcweir  *
26*cdf0e10cSrcweir  ************************************************************************/
27*cdf0e10cSrcweir 
28*cdf0e10cSrcweir #ifndef _CPPU_THREADPOOL_JOBQUEUE_HXX_
29*cdf0e10cSrcweir #define _CPPU_THREADPOOL_JOBQUEUE_HXX_
30*cdf0e10cSrcweir 
31*cdf0e10cSrcweir #include <list>
32*cdf0e10cSrcweir #include <sal/types.h>
33*cdf0e10cSrcweir 
34*cdf0e10cSrcweir #include <osl/conditn.h>
35*cdf0e10cSrcweir #include <osl/mutex.hxx>
36*cdf0e10cSrcweir 
37*cdf0e10cSrcweir #include <boost/shared_ptr.hpp>
38*cdf0e10cSrcweir 
39*cdf0e10cSrcweir namespace cppu_threadpool
40*cdf0e10cSrcweir {
41*cdf0e10cSrcweir     extern "C" typedef void (SAL_CALL RequestFun)(void *);
42*cdf0e10cSrcweir 
43*cdf0e10cSrcweir 	struct Job
44*cdf0e10cSrcweir 	{
45*cdf0e10cSrcweir 		void *pThreadSpecificData;
46*cdf0e10cSrcweir 		RequestFun * doRequest;
47*cdf0e10cSrcweir 	};
48*cdf0e10cSrcweir 
49*cdf0e10cSrcweir 	typedef	::std::list	< struct Job > JobList;
50*cdf0e10cSrcweir 
51*cdf0e10cSrcweir 	typedef	::std::list	< sal_Int64 > CallStackList;
52*cdf0e10cSrcweir 
53*cdf0e10cSrcweir 	class DisposedCallerAdmin;
54*cdf0e10cSrcweir 	typedef boost::shared_ptr<DisposedCallerAdmin> DisposedCallerAdminHolder;
55*cdf0e10cSrcweir 
56*cdf0e10cSrcweir 	class JobQueue
57*cdf0e10cSrcweir 	{
58*cdf0e10cSrcweir 	public:
59*cdf0e10cSrcweir 		JobQueue();
60*cdf0e10cSrcweir 		~JobQueue();
61*cdf0e10cSrcweir 
62*cdf0e10cSrcweir 		void add( void *pThreadSpecificData, RequestFun * doRequest );
63*cdf0e10cSrcweir 
64*cdf0e10cSrcweir 		void *enter( sal_Int64 nDisposeId , sal_Bool bReturnWhenNoJob = sal_False );
65*cdf0e10cSrcweir 		void dispose( sal_Int64 nDisposeId );
66*cdf0e10cSrcweir 
67*cdf0e10cSrcweir 		void suspend();
68*cdf0e10cSrcweir 		void resume();
69*cdf0e10cSrcweir 
70*cdf0e10cSrcweir 		sal_Bool isEmpty();
71*cdf0e10cSrcweir 		sal_Bool isCallstackEmpty();
72*cdf0e10cSrcweir 		sal_Bool isBusy();
73*cdf0e10cSrcweir 
74*cdf0e10cSrcweir 	private:
75*cdf0e10cSrcweir 		::osl::Mutex m_mutex;
76*cdf0e10cSrcweir 		JobList      m_lstJob;
77*cdf0e10cSrcweir 		CallStackList m_lstCallstack;
78*cdf0e10cSrcweir 		sal_Int32 m_nToDo;
79*cdf0e10cSrcweir 		sal_Bool m_bSuspended;
80*cdf0e10cSrcweir 		oslCondition m_cndWait;
81*cdf0e10cSrcweir 		DisposedCallerAdminHolder m_DisposedCallerAdmin;
82*cdf0e10cSrcweir 	};
83*cdf0e10cSrcweir }
84*cdf0e10cSrcweir 
85*cdf0e10cSrcweir #endif
86