1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
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
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
|
/******************************************************************************
*
* Copyright (C) 1997-2019 by Dimitri van Heesch.
*
* Permission to use, copy, modify, and distribute this software and its
* documentation under the terms of the GNU General Public License is hereby
* granted. No representations are made about the suitability of this software
* for any purpose. It is provided "as is" without express or implied warranty.
* See the GNU General Public License for more details.
*
* Documents produced by Doxygen are derivative works derived from the
* input used in their production; they are not affected by this license.
*
*/
#ifndef DOTRUNNER_H
#define DOTRUNNER_H
#include <string>
#include <thread>
#include <list>
#include <queue>
#include <mutex>
#include <condition_variable>
#include <memory>
#include "qcstring.h"
/** Helper class to run dot from doxygen from multiple threads. */
class DotRunner
{
struct DotJob
{
DotJob(const QCString &f, const QCString &o, const QCString &a)
: format(f), output(o), args(a) {}
QCString format;
QCString output;
QCString args;
};
public:
/** Creates a runner for a dot \a file. */
DotRunner(const QCString & absDotName, const QCString& md5Hash = QCString());
/** Adds an additional job to the run.
* Performing multiple jobs one file can be faster.
*/
void addJob(const QCString &format,const QCString &output);
/** Prevent cleanup of the dot file (for user provided dot files) */
void preventCleanUp() { m_cleanUp = false; }
/** Runs dot for all jobs added. */
bool run();
QCString getMd5Hash() { return m_md5Hash; }
static bool readBoundingBox(const QCString &fileName, int* width, int* height, bool isEps);
private:
QCString m_file;
QCString m_md5Hash;
QCString m_dotExe;
bool m_cleanUp;
std::vector<DotJob> m_jobs;
};
/** Queue of dot jobs to run. */
// all methods are thread save
class DotRunnerQueue
{
public:
void enqueue(DotRunner *runner);
DotRunner *dequeue();
size_t size() const;
private:
std::condition_variable m_bufferNotEmpty;
std::queue<DotRunner *> m_queue;
mutable std::mutex m_mutex;
};
/** Worker thread to execute a dot run */
class DotWorkerThread
{
public:
DotWorkerThread(DotRunnerQueue *queue);
~DotWorkerThread();
void run();
void start();
bool isRunning() { return m_thread && m_thread->joinable(); }
void wait() { m_thread->join(); }
private:
std::unique_ptr<std::thread> m_thread;
DotRunnerQueue *m_queue;
};
#endif
|
