simplejobprocessor.h 2.33 KB
Newer Older
1
2
3
4
// ================================================================================================
// 
// This file is part of the CAMPVis Software Framework.
// 
5
// If not explicitly stated otherwise: Copyright (C) 2012-2013, all rights reserved,
6
7
//      Christian Schulte zu Berge <christian.szb@in.tum.de>
//      Chair for Computer Aided Medical Procedures
8
9
//      Technische Universität München
//      Boltzmannstr. 3, 85748 Garching b. München, Germany
10
// 
11
12
// For a full list of authors and contributors, please refer to the file "AUTHORS.txt".
// 
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
27
28
// 
// ================================================================================================

#ifndef SIMPLEJOBPROCESSOR_H__
#define SIMPLEJOBPROCESSOR_H__

#include "tgt/singleton.h"
29
#include <tbb/task_group.h>
30

31
32
#include "core/coreapi.h"

33
34
35
36
37
38
namespace campvis {
    /**
     * Singleton class for managing and executing work items (jobs) in an asynchronous way.
     * Enqueued jobs are dispatched via the tbb::task_group interface as single tasks.
     * No priority schemes are implemented by now.
     */
39
    class CAMPVIS_CORE_API SimpleJobProcessor : public tgt::Singleton<SimpleJobProcessor> {
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
        friend class tgt::Singleton<SimpleJobProcessor>;

    public:
        /**
         * Destructor, cancels all unfinished jobs.
         */
        virtual ~SimpleJobProcessor();

        /**
         * Enqueues the given Job.
         * \param   job         Job to enqueue
         */
        template<class Func>
        void enqueueJob(const Func& f) {
            _taskGroup.run(f);
        };

    protected:
        SimpleJobProcessor();

        tbb::task_group _taskGroup;
    };

}

#define SimpleJobProc tgt::Singleton<SimpleJobProcessor>::getRef()

#endif // SIMPLEJOBPROCESSOR_H__