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
|
// Created on: 2017-06-16
// Created by: Natalia ERMOLAEVA
// Copyright (c) 2017 OPEN CASCADE SAS
//
// This file is part of Open CASCADE Technology software library.
//
// This library is free software; you can redistribute it and/or modify it under
// the terms of the GNU Lesser General Public License version 2.1 as published
// by the Free Software Foundation, with special exception defined in the file
// OCCT_LGPL_EXCEPTION.txt. Consult the file LICENSE_LGPL_21.txt included in OCCT
// distribution for complete text of the license and disclaimer of any warranty.
//
// Alternatively, this file may be used under the terms of Open CASCADE
// commercial license or contractual agreement.
#ifndef DFBrowser_Thread_H
#define DFBrowser_Thread_H
#include <Standard.hxx>
#include <Standard_WarningsDisable.hxx>
#include <QList>
#include <QObject>
#include <Standard_WarningsRestore.hxx>
class DFBrowser_Module;
class DFBrowser_ThreadItem;
class DFBrowser_Window;
class QThread;
//! /class DFBrowser_Thread
//! Starts algorithm item in a separate thread and perform some functionality by the algorithm(thread) is finished
class DFBrowser_Thread : public QObject
{
Q_OBJECT
public:
//! Constructor
Standard_EXPORT DFBrowser_Thread (DFBrowser_Window* theWindow);
//! Destructor
virtual ~DFBrowser_Thread() {}
//! Starts all candidate thread items
Standard_EXPORT void ProcessApplication();
//! Terminates all started threads.
Standard_EXPORT void TerminateThread();
protected:
//! Creates new Qt thread and starts the item. Connects to finished signal of thread.
//! \param theItem a thread item
void startThread (DFBrowser_ThreadItem* theItem);
protected slots:
//! Removes finished thread from the thread items and apply values of this thread
//! If this signal is come when another thread is processed, the current thread is stored in a cache and
//! is processed after the previous thread is processed.
void onFinished();
private:
QList<DFBrowser_ThreadItem*> myItems; //!< candidates to be processed in a thread
QList<QThread*> myStartedThreads; //!< container of started threads
DFBrowser_ThreadItem* myPostponedItem; //!< currently processed item in onFinished()
bool myIsFinishProcessing; //!< blocking state if onFinished() is started but has not been finished yet
};
#endif
|
