1*b1cdbd2cSJim Jagielski /**************************************************************
2*b1cdbd2cSJim Jagielski *
3*b1cdbd2cSJim Jagielski * Licensed to the Apache Software Foundation (ASF) under one
4*b1cdbd2cSJim Jagielski * or more contributor license agreements. See the NOTICE file
5*b1cdbd2cSJim Jagielski * distributed with this work for additional information
6*b1cdbd2cSJim Jagielski * regarding copyright ownership. The ASF licenses this file
7*b1cdbd2cSJim Jagielski * to you under the Apache License, Version 2.0 (the
8*b1cdbd2cSJim Jagielski * "License"); you may not use this file except in compliance
9*b1cdbd2cSJim Jagielski * with the License. You may obtain a copy of the License at
10*b1cdbd2cSJim Jagielski *
11*b1cdbd2cSJim Jagielski * http://www.apache.org/licenses/LICENSE-2.0
12*b1cdbd2cSJim Jagielski *
13*b1cdbd2cSJim Jagielski * Unless required by applicable law or agreed to in writing,
14*b1cdbd2cSJim Jagielski * software distributed under the License is distributed on an
15*b1cdbd2cSJim Jagielski * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
16*b1cdbd2cSJim Jagielski * KIND, either express or implied. See the License for the
17*b1cdbd2cSJim Jagielski * specific language governing permissions and limitations
18*b1cdbd2cSJim Jagielski * under the License.
19*b1cdbd2cSJim Jagielski *
20*b1cdbd2cSJim Jagielski *************************************************************/
21*b1cdbd2cSJim Jagielski
22*b1cdbd2cSJim Jagielski
23*b1cdbd2cSJim Jagielski
24*b1cdbd2cSJim Jagielski // MARKER(update_precomp.py): autogen include statement, do not remove
25*b1cdbd2cSJim Jagielski #include "precompiled_vcl.hxx"
26*b1cdbd2cSJim Jagielski
27*b1cdbd2cSJim Jagielski #define THREADEX_IMPLEMENTATION
28*b1cdbd2cSJim Jagielski #include <vcl/threadex.hxx>
29*b1cdbd2cSJim Jagielski #include <vcl/svapp.hxx>
30*b1cdbd2cSJim Jagielski
31*b1cdbd2cSJim Jagielski using namespace vcl;
32*b1cdbd2cSJim Jagielski
ThreadExecutor()33*b1cdbd2cSJim Jagielski ThreadExecutor::ThreadExecutor()
34*b1cdbd2cSJim Jagielski {
35*b1cdbd2cSJim Jagielski m_aFinish = osl_createCondition();
36*b1cdbd2cSJim Jagielski m_aThread = NULL;
37*b1cdbd2cSJim Jagielski }
38*b1cdbd2cSJim Jagielski
~ThreadExecutor()39*b1cdbd2cSJim Jagielski ThreadExecutor::~ThreadExecutor()
40*b1cdbd2cSJim Jagielski {
41*b1cdbd2cSJim Jagielski osl_destroyCondition( m_aFinish );
42*b1cdbd2cSJim Jagielski if( m_aThread )
43*b1cdbd2cSJim Jagielski osl_destroyThread( m_aThread );
44*b1cdbd2cSJim Jagielski }
45*b1cdbd2cSJim Jagielski
46*b1cdbd2cSJim Jagielski extern "C"
47*b1cdbd2cSJim Jagielski {
call_worker(void * pInstance)48*b1cdbd2cSJim Jagielski static void call_worker( void* pInstance )
49*b1cdbd2cSJim Jagielski {
50*b1cdbd2cSJim Jagielski ThreadExecutor::worker( pInstance );
51*b1cdbd2cSJim Jagielski }
52*b1cdbd2cSJim Jagielski }
53*b1cdbd2cSJim Jagielski
worker(void * pInstance)54*b1cdbd2cSJim Jagielski void ThreadExecutor::worker( void* pInstance )
55*b1cdbd2cSJim Jagielski {
56*b1cdbd2cSJim Jagielski ThreadExecutor* pThis = ((ThreadExecutor*)pInstance);
57*b1cdbd2cSJim Jagielski pThis->m_nReturn = pThis->doIt();
58*b1cdbd2cSJim Jagielski osl_setCondition( pThis->m_aFinish );
59*b1cdbd2cSJim Jagielski }
60*b1cdbd2cSJim Jagielski
execute()61*b1cdbd2cSJim Jagielski long ThreadExecutor::execute()
62*b1cdbd2cSJim Jagielski {
63*b1cdbd2cSJim Jagielski osl_resetCondition( m_aFinish );
64*b1cdbd2cSJim Jagielski if( m_aThread )
65*b1cdbd2cSJim Jagielski osl_destroyThread( m_aThread ), m_aThread = NULL;
66*b1cdbd2cSJim Jagielski m_aThread = osl_createThread( call_worker, this );
67*b1cdbd2cSJim Jagielski while( ! osl_checkCondition( m_aFinish ) )
68*b1cdbd2cSJim Jagielski Application::Reschedule();
69*b1cdbd2cSJim Jagielski return m_nReturn;
70*b1cdbd2cSJim Jagielski }
71*b1cdbd2cSJim Jagielski
72*b1cdbd2cSJim Jagielski
SolarThreadExecutor()73*b1cdbd2cSJim Jagielski SolarThreadExecutor::SolarThreadExecutor()
74*b1cdbd2cSJim Jagielski :m_nReturn( 0 )
75*b1cdbd2cSJim Jagielski ,m_bTimeout( false )
76*b1cdbd2cSJim Jagielski {
77*b1cdbd2cSJim Jagielski m_aStart = osl_createCondition();
78*b1cdbd2cSJim Jagielski m_aFinish = osl_createCondition();
79*b1cdbd2cSJim Jagielski }
80*b1cdbd2cSJim Jagielski
~SolarThreadExecutor()81*b1cdbd2cSJim Jagielski SolarThreadExecutor::~SolarThreadExecutor()
82*b1cdbd2cSJim Jagielski {
83*b1cdbd2cSJim Jagielski osl_destroyCondition( m_aStart );
84*b1cdbd2cSJim Jagielski osl_destroyCondition( m_aFinish );
85*b1cdbd2cSJim Jagielski }
86*b1cdbd2cSJim Jagielski
IMPL_LINK(SolarThreadExecutor,worker,void *,EMPTYARG)87*b1cdbd2cSJim Jagielski IMPL_LINK( SolarThreadExecutor, worker, void*, EMPTYARG )
88*b1cdbd2cSJim Jagielski {
89*b1cdbd2cSJim Jagielski if ( !m_bTimeout )
90*b1cdbd2cSJim Jagielski {
91*b1cdbd2cSJim Jagielski osl_setCondition( m_aStart );
92*b1cdbd2cSJim Jagielski m_nReturn = doIt();
93*b1cdbd2cSJim Jagielski osl_setCondition( m_aFinish );
94*b1cdbd2cSJim Jagielski }
95*b1cdbd2cSJim Jagielski return m_nReturn;
96*b1cdbd2cSJim Jagielski }
97*b1cdbd2cSJim Jagielski
impl_execute(const TimeValue * _pTimeout)98*b1cdbd2cSJim Jagielski long SolarThreadExecutor::impl_execute( const TimeValue* _pTimeout )
99*b1cdbd2cSJim Jagielski {
100*b1cdbd2cSJim Jagielski if( ::vos::OThread::getCurrentIdentifier() == Application::GetMainThreadIdentifier() )
101*b1cdbd2cSJim Jagielski {
102*b1cdbd2cSJim Jagielski osl_setCondition( m_aStart );
103*b1cdbd2cSJim Jagielski m_nReturn = doIt();
104*b1cdbd2cSJim Jagielski osl_setCondition( m_aFinish );
105*b1cdbd2cSJim Jagielski }
106*b1cdbd2cSJim Jagielski else
107*b1cdbd2cSJim Jagielski {
108*b1cdbd2cSJim Jagielski osl_resetCondition( m_aStart );
109*b1cdbd2cSJim Jagielski osl_resetCondition( m_aFinish );
110*b1cdbd2cSJim Jagielski sal_uLong nSolarMutexCount = Application::ReleaseSolarMutex();
111*b1cdbd2cSJim Jagielski sal_uLong nEvent = Application::PostUserEvent( LINK( this, SolarThreadExecutor, worker ) );
112*b1cdbd2cSJim Jagielski if ( osl_cond_result_timeout == osl_waitCondition( m_aStart, _pTimeout ) )
113*b1cdbd2cSJim Jagielski {
114*b1cdbd2cSJim Jagielski m_bTimeout = true;
115*b1cdbd2cSJim Jagielski Application::RemoveUserEvent( nEvent );
116*b1cdbd2cSJim Jagielski }
117*b1cdbd2cSJim Jagielski else
118*b1cdbd2cSJim Jagielski osl_waitCondition( m_aFinish, NULL );
119*b1cdbd2cSJim Jagielski if( nSolarMutexCount )
120*b1cdbd2cSJim Jagielski Application::AcquireSolarMutex( nSolarMutexCount );
121*b1cdbd2cSJim Jagielski }
122*b1cdbd2cSJim Jagielski return m_nReturn;
123*b1cdbd2cSJim Jagielski }
124