vcl/source/helper/threadex.cxx

   1 /*************************************************************************
   2  *
   3  * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER.
   4  *
   5  * Copyright 2008 by Sun Microsystems, Inc.
   6  *
   7  * OpenOffice.org - a multi-platform office productivity suite
   8  *
   9  * $RCSfile: threadex.cxx,v $
  10  * $Revision: 1.10 $
  11  *
  12  * This file is part of OpenOffice.org.
  13  *
  14  * OpenOffice.org is free software: you can redistribute it and/or modify
  15  * it under the terms of the GNU Lesser General Public License version 3
  16  * only, as published by the Free Software Foundation.
  17  *
  18  * OpenOffice.org is distributed in the hope that it will be useful,
  19  * but WITHOUT ANY WARRANTY; without even the implied warranty of
  20  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  21  * GNU Lesser General Public License version 3 for more details
  22  * (a copy is included in the LICENSE file that accompanied this code).
  23  *
  24  * You should have received a copy of the GNU Lesser General Public License
  25  * version 3 along with OpenOffice.org.  If not, see
  26  * <http://www.openoffice.org/license.html>
  27  * for a copy of the LGPLv3 License.
  28  *
  29  ************************************************************************/
  30
  31 // MARKER(update_precomp.py): autogen include statement, do not remove
  32 #include "precompiled_vcl.hxx"
  33
  34 #define THREADEX_IMPLEMENTATION
  35 #include <vcl/threadex.hxx>
  36 #include <vcl/svapp.hxx>
  37
  38 using namespace vcl;
  39
  40 ThreadExecutor::ThreadExecutor()
  41 {
  42     m_aFinish = osl_createCondition();
  43     m_aThread = NULL;
  44 }
  45
  46 ThreadExecutor::~ThreadExecutor()
  47 {
  48     osl_destroyCondition( m_aFinish );
  49     if( m_aThread )
  50         osl_destroyThread( m_aThread );
  51 }
  52
  53 extern "C"
  54 {
  55     static void call_worker( void* pInstance )
  56     {
  57         ThreadExecutor::worker( pInstance );
  58     }
  59 }
  60
  61 void ThreadExecutor::worker( void* pInstance )
  62 {
  63     ThreadExecutor* pThis = ((ThreadExecutor*)pInstance);
  64     pThis->m_nReturn = pThis->doIt();
  65     osl_setCondition( pThis->m_aFinish );
  66 }
  67
  68 long ThreadExecutor::execute()
  69 {
  70     osl_resetCondition( m_aFinish );
  71     if( m_aThread )
  72         osl_destroyThread( m_aThread ), m_aThread = NULL;
  73     m_aThread = osl_createThread( call_worker, this );
  74     while( ! osl_checkCondition( m_aFinish ) )
  75         Application::Reschedule();
  76     return m_nReturn;
  77 }
  78
  79
  80 SolarThreadExecutor::SolarThreadExecutor()
  81     :m_nReturn( 0 )
  82     ,m_bTimeout( false )
  83 {
  84     m_aStart = osl_createCondition();
  85     m_aFinish = osl_createCondition();
  86 }
  87
  88 SolarThreadExecutor::~SolarThreadExecutor()
  89 {
  90     osl_destroyCondition( m_aStart );
  91     osl_destroyCondition( m_aFinish );
  92 }
  93
  94 IMPL_LINK( SolarThreadExecutor, worker, void*, EMPTYARG )
  95 {
  96     if ( !m_bTimeout )
  97     {
  98         osl_setCondition( m_aStart );
  99         m_nReturn = doIt();
 100         osl_setCondition( m_aFinish );
 101     }
 102     return m_nReturn;
 103 }
 104
 105 long SolarThreadExecutor::impl_execute( const TimeValue* _pTimeout )
 106 {
 107     if( ::vos::OThread::getCurrentIdentifier() == Application::GetMainThreadIdentifier() )
 108     {
 109         osl_setCondition( m_aStart );
 110         m_nReturn = doIt();
 111         osl_setCondition( m_aFinish );
 112     }
 113     else
 114     {
 115         osl_resetCondition( m_aStart );
 116         osl_resetCondition( m_aFinish );
 117         ULONG nSolarMutexCount = Application::ReleaseSolarMutex();
 118         ULONG nEvent = Application::PostUserEvent( LINK( this, SolarThreadExecutor, worker ) );
 119         if ( osl_cond_result_timeout == osl_waitCondition( m_aStart, _pTimeout ) )
 120         {
 121             m_bTimeout = true;
 122             Application::RemoveUserEvent( nEvent );
 123         }
 124         else
 125             osl_waitCondition( m_aFinish, NULL );
 126         if( nSolarMutexCount )
 127             Application::AcquireSolarMutex( nSolarMutexCount );
 128     }
 129     return m_nReturn;
 130 }