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
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
|
/*=========================================================================
Program: Insight Segmentation & Registration Toolkit
Module: $RCSfile: itkProgressReporter.h,v $
Language: C++
Date: $Date: 2006-07-24 11:41:15 $
Version: $Revision: 1.11 $
Copyright (c) Insight Software Consortium. All rights reserved.
See ITKCopyright.txt or http://www.itk.org/HTML/Copyright.htm for details.
This software is distributed WITHOUT ANY WARRANTY; without even
the implied warranty of MERCHANTABILITY or FITNESS FOR A PARTICULAR
PURPOSE. See the above copyright notices for more information.
=========================================================================*/
#ifndef __itkProgressReporter_h
#define __itkProgressReporter_h
#include "itkProcessObject.h"
namespace itk
{
/** \class ProgressReporter
* \brief Implements progress tracking for a filter.
*
* This is a utility class for use by filter implementations in
* GenerateData() and ThreadedGenerateData().
*
* The class constructor sets the progress to 0, and the destructor
* sets it to 1. In between, there should be one call to
* CompletedPixel() per pixel. The reporter will automatically update
* the filter's progress at an interval resulting in the specified
* number of updates. The default number of updates is 100.
*
* Example usage:
*
* \code
* ProgressReporter progress(this, threadId,
* threadRegion.GetNumberOfPixels(), 100);
* for( each pixel )
* {
* ...
* progress.CompletedPixel();
* }
* \endcode
*
* When used in a non-threaded filter, the threadId argument should be 0.
*
* \sa
* This class is a tool for filter implementers to equip a filter to
* report on its progress. For information on how to acquire this
* progress information, see:
* - ProcessObject::ReportProgress()
* - Object::AddObserver()
*/
class ITKCommon_EXPORT ProgressReporter
{
public:
/** Constructor sets progress to 0 because the filter is starting. */
ProgressReporter(ProcessObject* filter, int threadId,
unsigned long numberOfPixels,
unsigned long numberOfUpdates = 100,
float initialProgress = 0.0f,
float progressWeight = 1.0f );
/** Destructor sets progress to 1 because the filter has finished. */
~ProgressReporter();
/** Called by a filter once per pixel. */
void CompletedPixel()
{
// Inline implementation for efficiency.
if(--m_PixelsBeforeUpdate == 0)
{
m_PixelsBeforeUpdate = m_PixelsPerUpdate;
m_CurrentPixel += m_PixelsPerUpdate;
// only thread 0 should update the progress of the filter
if (m_ThreadId == 0)
{
m_Filter->UpdateProgress(
m_CurrentPixel * m_InverseNumberOfPixels * m_ProgressWeight + m_InitialProgress);
}
// all threads needs to check the abort flag
if( m_Filter->GetAbortGenerateData() )
{
std::string msg;
ProcessAborted e(__FILE__, __LINE__);
msg += "Object " + std::string(m_Filter->GetNameOfClass()) + ": AbortGenerateDataOn";
e.SetDescription(msg);
throw e;
}
}
}
protected:
ProcessObject* m_Filter;
int m_ThreadId;
float m_InverseNumberOfPixels;
unsigned long m_CurrentPixel;
unsigned long m_PixelsPerUpdate;
unsigned long m_PixelsBeforeUpdate;
float m_InitialProgress;
float m_ProgressWeight;
private:
ProgressReporter(); //purposely not implemented
};
} // end namespace itk
#endif
|
