1 /**************************************************************
2  *
3  * Licensed to the Apache Software Foundation (ASF) under one
4  * or more contributor license agreements.  See the NOTICE file
5  * distributed with this work for additional information
6  * regarding copyright ownership.  The ASF licenses this file
7  * to you under the Apache License, Version 2.0 (the
8  * "License"); you may not use this file except in compliance
9  * with the License.  You may obtain a copy of the License at
10  *
11  *   http://www.apache.org/licenses/LICENSE-2.0
12  *
13  * Unless required by applicable law or agreed to in writing,
14  * software distributed under the License is distributed on an
15  * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
16  * KIND, either express or implied.  See the License for the
17  * specific language governing permissions and limitations
18  * under the License.
19  *
20  *************************************************************/
21 
22 
23 
24 // MARKER(update_precomp.py): autogen include statement, do not remove
25 #include "precompiled_cppu.hxx"
26 #include "jobqueue.hxx"
27 #include "threadpool.hxx"
28 
29 #include <osl/diagnose.h>
30 
31 using namespace ::osl;
32 
33 namespace cppu_threadpool {
34 
JobQueue()35 	JobQueue::JobQueue() :
36 		m_nToDo( 0 ),
37 		m_bSuspended( sal_False ),
38 		m_cndWait( osl_createCondition() )
39 	{
40 		osl_resetCondition( m_cndWait );
41 		m_DisposedCallerAdmin = DisposedCallerAdmin::getInstance();
42 	}
43 
~JobQueue()44 	JobQueue::~JobQueue()
45 	{
46 		osl_destroyCondition( m_cndWait );
47 	}
48 
49 
add(void * pThreadSpecificData,RequestFun * doRequest)50 	void JobQueue::add( void *pThreadSpecificData, RequestFun * doRequest )
51 	{
52 		MutexGuard guard( m_mutex );
53 		Job job = { pThreadSpecificData , doRequest };
54 		m_lstJob.push_back( job );
55 		if( ! m_bSuspended )
56 		{
57 			osl_setCondition( m_cndWait );
58 		}
59 		m_nToDo ++;
60 	}
61 
enter(sal_Int64 nDisposeId,sal_Bool bReturnWhenNoJob)62 	void *JobQueue::enter( sal_Int64 nDisposeId , sal_Bool bReturnWhenNoJob )
63 	{
64 		void *pReturn = 0;
65 		{
66 			// synchronize with the dispose calls
67 			MutexGuard guard( m_mutex );
68 			if( m_DisposedCallerAdmin->isDisposed( nDisposeId ) )
69 			{
70 				return 0;
71 			}
72 			m_lstCallstack.push_front( nDisposeId );
73 		}
74 
75 
76 		while( sal_True )
77 		{
78 			if( bReturnWhenNoJob )
79 			{
80 				MutexGuard guard( m_mutex );
81 				if( m_lstJob.empty() )
82 				{
83 					break;
84 				}
85 			}
86 
87 			osl_waitCondition( m_cndWait , 0 );
88 
89 			struct Job job={0,0};
90 			{
91 				// synchronize with add and dispose calls
92 				MutexGuard guard( m_mutex );
93 
94 				if( 0 == m_lstCallstack.front() )
95 				{
96 					// disposed !
97                     if( m_lstJob.empty() )
98                     {
99                         osl_resetCondition( m_cndWait );
100                     }
101 					break;
102 				}
103 
104 				OSL_ASSERT( ! m_lstJob.empty() );
105 				if( ! m_lstJob.empty() )
106 				{
107 					job = m_lstJob.front();
108 					m_lstJob.pop_front();
109 				}
110 				if( m_lstJob.empty() )
111 				{
112 					osl_resetCondition( m_cndWait );
113 				}
114 			}
115 
116 			if( job.doRequest )
117 			{
118 				job.doRequest( job.pThreadSpecificData );
119 				m_nToDo --;
120 			}
121 			else
122 			{
123 				m_nToDo --;
124 				pReturn = job.pThreadSpecificData;
125 				break;
126 			}
127 		}
128 
129 		{
130 			// synchronize with the dispose calls
131 			MutexGuard guard( m_mutex );
132 			m_lstCallstack.pop_front();
133 		}
134 
135 		return pReturn;
136 	}
137 
dispose(sal_Int64 nDisposeId)138 	void JobQueue::dispose( sal_Int64 nDisposeId )
139 	{
140 		MutexGuard guard( m_mutex );
141 		for( CallStackList::iterator ii = m_lstCallstack.begin() ;
142 			 ii != m_lstCallstack.end() ;
143 			 ++ii )
144 		{
145 			if( (*ii) == nDisposeId )
146 			{
147 				(*ii) = 0;
148 			}
149 		}
150 
151 		if( !m_lstCallstack.empty()  && ! m_lstCallstack.front() )
152 		{
153 			// The thread is waiting for a disposed pCallerId, let it go
154 			osl_setCondition( m_cndWait );
155 		}
156 	}
157 
suspend()158 	void JobQueue::suspend()
159 	{
160 		MutexGuard guard( m_mutex );
161 		m_bSuspended = sal_True;
162 	}
163 
resume()164 	void JobQueue::resume()
165 	{
166 		MutexGuard guard( m_mutex );
167 		m_bSuspended = sal_False;
168 		if( ! m_lstJob.empty() )
169 		{
170 			osl_setCondition( m_cndWait );
171 		}
172 	}
173 
isEmpty()174 	sal_Bool JobQueue::isEmpty()
175 	{
176 		MutexGuard guard( m_mutex );
177 		return m_lstJob.empty();
178 	}
179 
isCallstackEmpty()180 	sal_Bool JobQueue::isCallstackEmpty()
181 	{
182 		MutexGuard guard( m_mutex );
183 		return m_lstCallstack.empty();
184 	}
185 
isBusy()186 	sal_Bool JobQueue::isBusy()
187 	{
188 		return m_nToDo > 0;
189 	}
190 
191 
192 }
193