1*129fa3d1SAndrew Rist /**************************************************************
2cdf0e10cSrcweir *
3*129fa3d1SAndrew Rist * Licensed to the Apache Software Foundation (ASF) under one
4*129fa3d1SAndrew Rist * or more contributor license agreements. See the NOTICE file
5*129fa3d1SAndrew Rist * distributed with this work for additional information
6*129fa3d1SAndrew Rist * regarding copyright ownership. The ASF licenses this file
7*129fa3d1SAndrew Rist * to you under the Apache License, Version 2.0 (the
8*129fa3d1SAndrew Rist * "License"); you may not use this file except in compliance
9*129fa3d1SAndrew Rist * with the License. You may obtain a copy of the License at
10*129fa3d1SAndrew Rist *
11*129fa3d1SAndrew Rist * http://www.apache.org/licenses/LICENSE-2.0
12*129fa3d1SAndrew Rist *
13*129fa3d1SAndrew Rist * Unless required by applicable law or agreed to in writing,
14*129fa3d1SAndrew Rist * software distributed under the License is distributed on an
15*129fa3d1SAndrew Rist * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
16*129fa3d1SAndrew Rist * KIND, either express or implied. See the License for the
17*129fa3d1SAndrew Rist * specific language governing permissions and limitations
18*129fa3d1SAndrew Rist * under the License.
19*129fa3d1SAndrew Rist *
20*129fa3d1SAndrew Rist *************************************************************/
21*129fa3d1SAndrew Rist
22*129fa3d1SAndrew Rist
23cdf0e10cSrcweir
24cdf0e10cSrcweir // MARKER(update_precomp.py): autogen include statement, do not remove
25cdf0e10cSrcweir #include "precompiled_cppu.hxx"
26cdf0e10cSrcweir #include <stdio.h>
27cdf0e10cSrcweir #include <osl/diagnose.h>
28cdf0e10cSrcweir #include <uno/threadpool.h>
29cdf0e10cSrcweir
30cdf0e10cSrcweir #include <rtl/instance.hxx>
31cdf0e10cSrcweir
32cdf0e10cSrcweir #include "thread.hxx"
33cdf0e10cSrcweir #include "jobqueue.hxx"
34cdf0e10cSrcweir #include "threadpool.hxx"
35cdf0e10cSrcweir
36cdf0e10cSrcweir
37cdf0e10cSrcweir using namespace osl;
38cdf0e10cSrcweir extern "C" {
39cdf0e10cSrcweir
cppu_requestThreadWorker(void * pVoid)40cdf0e10cSrcweir void SAL_CALL cppu_requestThreadWorker( void *pVoid )
41cdf0e10cSrcweir {
42cdf0e10cSrcweir ::cppu_threadpool::ORequestThread *pThread = ( ::cppu_threadpool::ORequestThread * ) pVoid;
43cdf0e10cSrcweir
44cdf0e10cSrcweir pThread->run();
45cdf0e10cSrcweir pThread->onTerminated();
46cdf0e10cSrcweir }
47cdf0e10cSrcweir
48cdf0e10cSrcweir }
49cdf0e10cSrcweir
50cdf0e10cSrcweir namespace cppu_threadpool {
51cdf0e10cSrcweir
52cdf0e10cSrcweir // ----------------------------------------------------------------------------------
~ThreadAdmin()53cdf0e10cSrcweir ThreadAdmin::~ThreadAdmin()
54cdf0e10cSrcweir {
55cdf0e10cSrcweir #if OSL_DEBUG_LEVEL > 1
56cdf0e10cSrcweir if( m_lst.size() )
57cdf0e10cSrcweir {
58cdf0e10cSrcweir fprintf( stderr, "%lu Threads left\n" , static_cast<unsigned long>(m_lst.size()) );
59cdf0e10cSrcweir }
60cdf0e10cSrcweir #endif
61cdf0e10cSrcweir }
62cdf0e10cSrcweir
add(ORequestThread * p)63cdf0e10cSrcweir void ThreadAdmin::add( ORequestThread *p )
64cdf0e10cSrcweir {
65cdf0e10cSrcweir MutexGuard aGuard( m_mutex );
66cdf0e10cSrcweir m_lst.push_back( p );
67cdf0e10cSrcweir }
68cdf0e10cSrcweir
remove(ORequestThread * p)69cdf0e10cSrcweir void ThreadAdmin::remove( ORequestThread * p )
70cdf0e10cSrcweir {
71cdf0e10cSrcweir MutexGuard aGuard( m_mutex );
72cdf0e10cSrcweir ::std::list< ORequestThread * >::iterator ii = ::std::find( m_lst.begin(), m_lst.end(), p );
73cdf0e10cSrcweir OSL_ASSERT( ii != m_lst.end() );
74cdf0e10cSrcweir m_lst.erase( ii );
75cdf0e10cSrcweir }
76cdf0e10cSrcweir
join()77cdf0e10cSrcweir void ThreadAdmin::join()
78cdf0e10cSrcweir {
79cdf0e10cSrcweir ORequestThread *pCurrent;
80cdf0e10cSrcweir do
81cdf0e10cSrcweir {
82cdf0e10cSrcweir pCurrent = 0;
83cdf0e10cSrcweir {
84cdf0e10cSrcweir MutexGuard aGuard( m_mutex );
85cdf0e10cSrcweir if( ! m_lst.empty() )
86cdf0e10cSrcweir {
87cdf0e10cSrcweir pCurrent = m_lst.front();
88cdf0e10cSrcweir pCurrent->setDeleteSelf( sal_False );
89cdf0e10cSrcweir }
90cdf0e10cSrcweir }
91cdf0e10cSrcweir if ( pCurrent )
92cdf0e10cSrcweir {
93cdf0e10cSrcweir pCurrent->join();
94cdf0e10cSrcweir delete pCurrent;
95cdf0e10cSrcweir }
96cdf0e10cSrcweir } while( pCurrent );
97cdf0e10cSrcweir }
98cdf0e10cSrcweir
99cdf0e10cSrcweir struct theThreadAdmin : public rtl::StaticWithInit< ThreadAdminHolder, theThreadAdmin >
100cdf0e10cSrcweir {
operator ()cppu_threadpool::theThreadAdmin101cdf0e10cSrcweir ThreadAdminHolder operator () () {
102cdf0e10cSrcweir ThreadAdminHolder aRet(new ThreadAdmin());
103cdf0e10cSrcweir return aRet;
104cdf0e10cSrcweir }
105cdf0e10cSrcweir };
106cdf0e10cSrcweir
getInstance()107cdf0e10cSrcweir ThreadAdminHolder& ThreadAdmin::getInstance()
108cdf0e10cSrcweir {
109cdf0e10cSrcweir return theThreadAdmin::get();
110cdf0e10cSrcweir }
111cdf0e10cSrcweir
112cdf0e10cSrcweir // ----------------------------------------------------------------------------------
ORequestThread(JobQueue * pQueue,const ByteSequence & aThreadId,sal_Bool bAsynchron)113cdf0e10cSrcweir ORequestThread::ORequestThread( JobQueue *pQueue,
114cdf0e10cSrcweir const ByteSequence &aThreadId,
115cdf0e10cSrcweir sal_Bool bAsynchron )
116cdf0e10cSrcweir : m_thread( 0 )
117cdf0e10cSrcweir , m_aThreadAdmin( ThreadAdmin::getInstance() )
118cdf0e10cSrcweir , m_pQueue( pQueue )
119cdf0e10cSrcweir , m_aThreadId( aThreadId )
120cdf0e10cSrcweir , m_bAsynchron( bAsynchron )
121cdf0e10cSrcweir , m_bDeleteSelf( sal_True )
122cdf0e10cSrcweir {
123cdf0e10cSrcweir m_aThreadAdmin->add( this );
124cdf0e10cSrcweir }
125cdf0e10cSrcweir
126cdf0e10cSrcweir
~ORequestThread()127cdf0e10cSrcweir ORequestThread::~ORequestThread()
128cdf0e10cSrcweir {
129cdf0e10cSrcweir if (m_thread != 0)
130cdf0e10cSrcweir {
131cdf0e10cSrcweir osl_destroyThread(m_thread);
132cdf0e10cSrcweir }
133cdf0e10cSrcweir }
134cdf0e10cSrcweir
135cdf0e10cSrcweir
setTask(JobQueue * pQueue,const ByteSequence & aThreadId,sal_Bool bAsynchron)136cdf0e10cSrcweir void ORequestThread::setTask( JobQueue *pQueue,
137cdf0e10cSrcweir const ByteSequence &aThreadId,
138cdf0e10cSrcweir sal_Bool bAsynchron )
139cdf0e10cSrcweir {
140cdf0e10cSrcweir m_pQueue = pQueue;
141cdf0e10cSrcweir m_aThreadId = aThreadId;
142cdf0e10cSrcweir m_bAsynchron = bAsynchron;
143cdf0e10cSrcweir }
144cdf0e10cSrcweir
create()145cdf0e10cSrcweir sal_Bool ORequestThread::create()
146cdf0e10cSrcweir {
147cdf0e10cSrcweir OSL_ASSERT(m_thread == 0); // only one running thread per instance
148cdf0e10cSrcweir
149cdf0e10cSrcweir m_thread = osl_createSuspendedThread( cppu_requestThreadWorker, (void*)this);
150cdf0e10cSrcweir if ( m_thread )
151cdf0e10cSrcweir {
152cdf0e10cSrcweir osl_resumeThread( m_thread );
153cdf0e10cSrcweir }
154cdf0e10cSrcweir
155cdf0e10cSrcweir return m_thread != 0;
156cdf0e10cSrcweir }
157cdf0e10cSrcweir
join()158cdf0e10cSrcweir void ORequestThread::join()
159cdf0e10cSrcweir {
160cdf0e10cSrcweir osl_joinWithThread( m_thread );
161cdf0e10cSrcweir }
162cdf0e10cSrcweir
onTerminated()163cdf0e10cSrcweir void ORequestThread::onTerminated()
164cdf0e10cSrcweir {
165cdf0e10cSrcweir m_aThreadAdmin->remove( this );
166cdf0e10cSrcweir if( m_bDeleteSelf )
167cdf0e10cSrcweir {
168cdf0e10cSrcweir delete this;
169cdf0e10cSrcweir }
170cdf0e10cSrcweir }
171cdf0e10cSrcweir
run()172cdf0e10cSrcweir void ORequestThread::run()
173cdf0e10cSrcweir {
174cdf0e10cSrcweir ThreadPoolHolder theThreadPool = cppu_threadpool::ThreadPool::getInstance();
175cdf0e10cSrcweir
176cdf0e10cSrcweir while ( m_pQueue )
177cdf0e10cSrcweir {
178cdf0e10cSrcweir if( ! m_bAsynchron )
179cdf0e10cSrcweir {
180cdf0e10cSrcweir if ( !uno_bindIdToCurrentThread( m_aThreadId.getHandle() ) )
181cdf0e10cSrcweir {
182cdf0e10cSrcweir OSL_ASSERT( false );
183cdf0e10cSrcweir }
184cdf0e10cSrcweir }
185cdf0e10cSrcweir
186cdf0e10cSrcweir while( ! m_pQueue->isEmpty() )
187cdf0e10cSrcweir {
188cdf0e10cSrcweir // Note : Oneways should not get a disposable disposeid,
189cdf0e10cSrcweir // It does not make sense to dispose a call in this state.
190cdf0e10cSrcweir // That's way we put it an disposeid, that can't be used otherwise.
191cdf0e10cSrcweir m_pQueue->enter(
192cdf0e10cSrcweir sal::static_int_cast< sal_Int64 >(
193cdf0e10cSrcweir reinterpret_cast< sal_IntPtr >(this)),
194cdf0e10cSrcweir sal_True );
195cdf0e10cSrcweir
196cdf0e10cSrcweir if( m_pQueue->isEmpty() )
197cdf0e10cSrcweir {
198cdf0e10cSrcweir theThreadPool->revokeQueue( m_aThreadId , m_bAsynchron );
199cdf0e10cSrcweir // Note : revokeQueue might have failed because m_pQueue.isEmpty()
200cdf0e10cSrcweir // may be false (race).
201cdf0e10cSrcweir }
202cdf0e10cSrcweir }
203cdf0e10cSrcweir
204cdf0e10cSrcweir delete m_pQueue;
205cdf0e10cSrcweir m_pQueue = 0;
206cdf0e10cSrcweir
207cdf0e10cSrcweir if( ! m_bAsynchron )
208cdf0e10cSrcweir {
209cdf0e10cSrcweir uno_releaseIdFromCurrentThread();
210cdf0e10cSrcweir }
211cdf0e10cSrcweir
212cdf0e10cSrcweir theThreadPool->waitInPool( this );
213cdf0e10cSrcweir }
214cdf0e10cSrcweir }
215cdf0e10cSrcweir }
216