sw/source/core/docnode/observablethread.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: observablethread.cxx,v $
  10  * $Revision: 1.3 $
  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 #include "precompiled_sw.hxx"
  31 #include <observablethread.hxx>
  32
  33 #include <boost/shared_ptr.hpp>
  34
  35 /** class for an observable thread
  36
  37     OD 2007-01-29 #i73788#
  38
  39     @author OD
  40 */
  41 ObservableThread::ObservableThread()
  42     : mnRefCount( 0 ),
  43       mnThreadID( 0 ),
  44       mpThreadListener()
  45 {
  46 }
  47
  48 ObservableThread::~ObservableThread()
  49 {
  50 }
  51
  52 oslInterlockedCount ObservableThread::acquire()
  53 {
  54     return osl_incrementInterlockedCount( &mnRefCount );
  55 }
  56
  57 oslInterlockedCount ObservableThread::release()
  58 {
  59     oslInterlockedCount nCount( osl_decrementInterlockedCount( &mnRefCount ) );
  60     if ( nCount == 0 )
  61     {
  62         delete this;
  63         return nCount;
  64     }
  65
  66     return nCount;
  67 }
  68
  69 void ObservableThread::SetListener( boost::weak_ptr< IFinishedThreadListener > pThreadListener,
  70                                     const oslInterlockedCount nThreadID )
  71 {
  72     mpThreadListener = pThreadListener;
  73     mnThreadID = nThreadID;
  74 }
  75
  76 void SAL_CALL ObservableThread::run()
  77 {
  78     acquire();
  79
  80     threadFunction();
  81 }
  82
  83 void SAL_CALL ObservableThread::onTerminated()
  84 {
  85     threadFinished();
  86
  87     // notify observer
  88     boost::shared_ptr< IFinishedThreadListener > pThreadListener = mpThreadListener.lock();
  89     if ( pThreadListener )
  90     {
  91         pThreadListener->NotifyAboutFinishedThread( mnThreadID );
  92     }
  93
  94     release();
  95 }
  96
  97 void ObservableThread::threadFinished()
  98 {
  99     // empty default implementation
 100 }