1 /*************************************************************************
2  *
3  * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER.
4  *
5  * Copyright 2000, 2010 Oracle and/or its affiliates.
6  *
7  * OpenOffice.org - a multi-platform office productivity suite
8  *
9  * This file is part of OpenOffice.org.
10  *
11  * OpenOffice.org is free software: you can redistribute it and/or modify
12  * it under the terms of the GNU Lesser General Public License version 3
13  * only, as published by the Free Software Foundation.
14  *
15  * OpenOffice.org is distributed in the hope that it will be useful,
16  * but WITHOUT ANY WARRANTY; without even the implied warranty of
17  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
18  * GNU Lesser General Public License version 3 for more details
19  * (a copy is included in the LICENSE file that accompanied this code).
20  *
21  * You should have received a copy of the GNU Lesser General Public License
22  * version 3 along with OpenOffice.org.  If not, see
23  * <http://www.openoffice.org/license.html>
24  * for a copy of the LGPLv3 License.
25  *
26  ************************************************************************/
27 #include "precompiled_sw.hxx"
28 #include <observablethread.hxx>
29 
30 #include <boost/shared_ptr.hpp>
31 
32 /** class for an observable thread
33 
34     OD 2007-01-29 #i73788#
35 
36     @author OD
37 */
38 ObservableThread::ObservableThread()
39     : mnRefCount( 0 ),
40       mnThreadID( 0 ),
41       mpThreadListener()
42 {
43 }
44 
45 ObservableThread::~ObservableThread()
46 {
47 }
48 
49 oslInterlockedCount ObservableThread::acquire()
50 {
51     return osl_incrementInterlockedCount( &mnRefCount );
52 }
53 
54 oslInterlockedCount ObservableThread::release()
55 {
56     oslInterlockedCount nCount( osl_decrementInterlockedCount( &mnRefCount ) );
57     if ( nCount == 0 )
58     {
59         delete this;
60         return nCount;
61     }
62 
63     return nCount;
64 }
65 
66 void ObservableThread::SetListener( boost::weak_ptr< IFinishedThreadListener > pThreadListener,
67                                     const oslInterlockedCount nThreadID )
68 {
69     mpThreadListener = pThreadListener;
70     mnThreadID = nThreadID;
71 }
72 
73 void SAL_CALL ObservableThread::run()
74 {
75     acquire();
76 
77     threadFunction();
78 }
79 
80 void SAL_CALL ObservableThread::onTerminated()
81 {
82     threadFinished();
83 
84     // notify observer
85     boost::shared_ptr< IFinishedThreadListener > pThreadListener = mpThreadListener.lock();
86     if ( pThreadListener )
87     {
88         pThreadListener->NotifyAboutFinishedThread( mnThreadID );
89     }
90 
91     release();
92 }
93 
94 void ObservableThread::threadFinished()
95 {
96     // empty default implementation
97 }
98