runnable.cpp 2.15 KB
Newer Older
1
2
// ================================================================================================
// 
schultezub's avatar
schultezub committed
3
// This file is part of the CAMPVis Software Framework.
4
// 
5
// If not explicitly stated otherwise: Copyright (C) 2012-2014, all rights reserved,
schultezub's avatar
schultezub committed
6
//      Christian Schulte zu Berge <christian.szb@in.tum.de>
7
//      Chair for Computer Aided Medical Procedures
8
9
//      Technische Universitaet Muenchen
//      Boltzmannstr. 3, 85748 Garching b. Muenchen, Germany
10
// 
schultezub's avatar
schultezub committed
11
// For a full list of authors and contributors, please refer to the file "AUTHORS.txt".
12
// 
13
14
15
16
// Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file 
// except in compliance with the License. You may obtain a copy of the License at
// 
// http://www.apache.org/licenses/LICENSE-2.0
17
// 
18
19
20
21
// Unless required by applicable law or agreed to in writing, software distributed under the 
// License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, 
// either express or implied. See the License for the specific language governing permissions 
// and limitations under the License.
22
23
24
// 
// ================================================================================================

25
26
#include "runnable.h"

schultezub's avatar
schultezub committed
27
namespace campvis {
28
29
30
31
32
33
34
35
    namespace {
        void invokeThread(Runnable* r) {
            r->run();
        }
    }

    Runnable::Runnable() 
        : _stopExecution()
schultezub's avatar
schultezub committed
36
        , _thread(0) 
37
38
    {
        _stopExecution = false;
39
        _running = false;
40
41
42
    }

    Runnable::~Runnable() {
43
44
45
        if (_running)
            stop();

46
	    delete _thread;
47
48
49
    }

    void Runnable::stop() {
50
51
52
        if (!_running || _thread == 0)
            return;

53
54
        _stopExecution = true; 
        try { 
schultezub's avatar
schultezub committed
55
56
            if (_thread->joinable())
                _thread->join(); 
57
58

            _running = false;
59
60
        } 
        catch(std::exception& e) { 
schultezub's avatar
schultezub committed
61
            LERRORC("CAMPVis.core.tools.Runnable", "Caught exception during _thread.join: " << e.what());
62
63
64
65
        } 
    }

    void Runnable::start() { 
schultezub's avatar
schultezub committed
66
        _thread = new std::thread(&invokeThread, this);
67
        _running = true;
68
69
70
    }
}