Generalization of a task that can be run in parallel.
More...
Inherits Task.
Inherited by AGC< T >, Array1DStacker< fT, ArrT >, Array2DCopier< T >, Array2DInterpol, Array2DReSampler< T, TT >, Array3DCopier< T >, Array3DFloodfill< T >, Array3DUdfTrcRestorer< T >, ArrayMath::ArrOperExec< ArrType, SumType, OperType >, ArrayMath::CumArrOperExec< ArrType, SumType, OperType, RetType >, ArrayNDDataExtracter< T >, ArrayUdfValReplacer< T >, ArrayUdfValRestorer< T >, BendPointFinderBase, BodyVolumeCalculator, Convolver2D< T >, Convolver3D< T >, Convolver3D< float >, DataDistributionExtracter< vT >, DelaunayTriangulator, DensityCalc, DPSDensityCalcND, DPSFromVolumeFiller, EM::EMObjectPosSelector, EM::Expl2ImplBodyExtracter, EM::HorizonMerger, FaultTraceExtractor, Fourier::CC::CC1D, FourierInterpol1D, FourierInterpol2D, FourierInterpol3D, Geometry::ArrayTesselator, ImageResizer, Implicit2MarchingCubes, Line2DInterSectionFinder, LogCubeCreator, MarchingCubes2Implicit, MarchingCubesSurfaceEditor, MemCopier< T >, MemSetter< T >, MemValReplacer< T >, MuteArrayExtracter< T >, Stats::ParallelCalc< float >, ParallelDTetrahedralator, ParallelSorter< T >, PreStack::AngleMuteComputer, PreStack::Processor, RaySynthGenerator, RayTracer1D, RayTracerRunner, ReflectivitySampler, SampledExtremeFinderND< T >, Seis::MultiTraceSynthGenerator, Seis::ParallelFSLoader2D, Seis::ParallelFSLoader3D, SeisZAxisStretcher, Smoother1D< T >, Smoother1D< float >, Stats::ParallelCalc< T >, ValueSeriesGetAll< T >, VDA2DBitMapGenerator [private], Vel::VolumeConverter, visBase::HorizonSectionTilePosSetup, visBase::HorizonTileRenderPreparer, visBase::HorizonTileResolutionTesselator, VolProc::StatsCalculatorTask, VolumeDataPackZAxisTransformer, Well::LogSampler, ZAxisTransformer, and ZAxisTransformPointGenerator.
|
| virtual bool | doWork (int64_t start, int64_t stop, int threadidx)=0 |
| |
| virtual bool | doPrepare (int nrthreads) |
| |
| virtual bool | doFinish (bool success) |
| |
|
| static uiString | tr (const char *text, const char *disambiguation=0, int pluralnr=-1) |
| |
| static uiString | legacyTr (const char *text, const char *disambiguation=0, int pluralnr=-1) |
| |
Generalization of a task that can be run in parallel.
Any task that has a fixed number of computations that are independent (i.e. they don't need to be done in a certain order) can inherit ParallelTask and be executed in parallel by calling the ParallelTask::execute().
Example of usage:
float result[N];
for ( int idx=0; idx<N; idx++ )
result[idx] = input1[idx]* function( idx, other, variables );
Could be made parallel by adding the class:
{
public:
{
{
result[idx] = input1[idx] *
function( idx, other, variables );
}
return true;
}
};
and in use that instead of the for-loop:
CalcClass myclass( N, my, parameters );
myclass.exectute();
| virtual ParallelTask::~ParallelTask |
( |
| ) |
|
|
virtual |
| ParallelTask::ParallelTask |
( |
const char * |
nm = 0 | ) |
|
|
protected |
| void ParallelTask::addToNrDone |
( |
int64_t |
increment | ) |
|
|
protected |
Call this from within your thread to say that you have done something. Do NOT call in very fast loops at every idx since it can impact negatively performance
| int64_t ParallelTask::calculateThreadSize |
( |
int64_t |
totalnr, |
|
|
int |
nrthreads, |
|
|
int |
thread |
|
) |
| const |
|
protected |
| virtual bool ParallelTask::doFinish |
( |
bool |
success | ) |
|
|
inlineprivatevirtual |
Called after all doWork have finished.
- Parameters
-
| success | indicates whether all doWork returned true. |
Reimplemented in Stats::ParallelCalc< T >, FaultTraceExtractor2D, ArrayMath::CumArrOperExec< ArrType, SumType, OperType, RetType >, FaultTraceExtractor, MemValReplacer< T >, FourierInterpol3D, ParallelSorter< T >, visBase::HorizonSectionTilePosSetup, Line2DInterSectionFinder, FourierInterpol2D, Array2DInterpol, LogCubeCreator, MarchingCubesSurfaceEditor, FourierInterpol1D, RaySynthGenerator, EM::Horizon3DMerger, Stats::ParallelCalc< T >, Stats::ParallelCalc< float >, SeisZAxisStretcher, PreStack::AngleMuteComputer, Vel::VolumeConverter, ReflectivitySampler, BendPointFinderBase, VolumeDataPackZAxisTransformer, ZAxisTransformPointGenerator, and ImageResizer.
| virtual bool ParallelTask::doPrepare |
( |
int |
nrthreads | ) |
|
|
inlineprivatevirtual |
Called once, before any doWork is called.
Reimplemented in MuteArrayExtracter< T >, ArrayUdfValReplacer< T >, Array3DCopier< T >, Array2DCopier< T >, Well::LogSampler, ArrayMath::ArrOperExec< ArrType, SumType, OperType >, FaultTraceExtractor2D, FaultTraceExtractor3D, Seis::MultiTraceSynthGenerator, MarchingCubes2Implicit, FaultTraceExtractor, MemValReplacer< T >, FourierInterpol3D, TriangulationArray2DInterpol, DelaunayTriangulator, ParallelDTetrahedralator, Seis::ParallelFSLoader2D, ParallelSorter< T >, MemCopier< T >, EM::Expl2ImplBodyExtracter, FourierInterpol2D, Array2DInterpol, Seis::ParallelFSLoader3D, ArrayMath::CumArrOperExec< ArrType, SumType, OperType, RetType >, PreStack::AngleMute, LogCubeCreator, RayTracer1D, InverseDistanceArray2DInterpol, Fourier::CC::CC1D, visBase::HorizonTileRenderPreparer, DataDistributionExtracter< vT >, MarchingCubesSurfaceEditor, MemSetter< T >, FourierInterpol1D, RaySynthGenerator, Convolver2D< T >, Smoother1D< T >, Stats::ParallelCalc< T >, Smoother1D< float >, Stats::ParallelCalc< float >, SeisZAxisStretcher, visBase::HorizonTileResolutionTesselator, ZAxisTransformer, PreStack::AngleMuteComputer, Vel::VolumeConverter, ReflectivitySampler, EM::EMObjectPosSelector, BendPointFinderBase, VolumeDataPackZAxisTransformer, Array1DStacker< fT, ArrT >, AGC< T >, ZAxisTransformPointGenerator, ContinuousCurvatureArray2DInterpol, and ImageResizer.
| virtual bool ParallelTask::doWork |
( |
int64_t |
start, |
|
|
int64_t |
stop, |
|
|
int |
threadidx |
|
) |
| |
|
privatepure virtual |
| bool ParallelTask::execute |
( |
| ) |
|
|
inlinevirtual |
Runs the process the desired number of times.
- Note
- that the function has static threads (normally the same number as there are processors on the machine), and these static threads will be shared by all instances of ParallelTask::execute.
Implements Task.
| virtual bool ParallelTask::executeParallel |
( |
bool |
parallel | ) |
|
|
virtual |
| static uiString ParallelTask::legacyTr |
( |
const char * |
text, |
|
|
const char * |
disambiguation = 0, |
|
|
int |
pluralnr = -1 |
|
) |
| |
|
inlinestaticprivate |
| virtual int ParallelTask::maxNrThreads |
( |
| ) |
const |
|
protectedvirtual |
| virtual int ParallelTask::minThreadSize |
( |
| ) |
const |
|
inlineprotectedvirtual |
| int64_t ParallelTask::nrDone |
( |
| ) |
const |
|
virtual |
| virtual int64_t ParallelTask::nrIterations |
( |
| ) |
const |
|
protectedpure virtual |
- Returns
- the number of times the process should be run.
Implemented in MuteArrayExtracter< T >, Array3DUdfTrcRestorer< T >, ArrayUdfValRestorer< T >, ArrayUdfValReplacer< T >, Array3DCopier< T >, Array2DCopier< T >, ArrayNDDataExtracter< T >, Well::LogSampler, DPSFromVolumeFiller, ArrayMath::ArrOperExec< ArrType, SumType, OperType >, ExtensionArray2DInterpol, Seis::MultiTraceSynthGenerator, MarchingCubes2Implicit, FaultTraceExtractor, FourierInterpol3D, TriangulationArray2DInterpol, DelaunayTriangulator, ParallelDTetrahedralator, MemValReplacer< T >, Seis::ParallelFSLoader2D, Implicit2MarchingCubes, VDA2DBitMapGenerator, ParallelSorter< T >, visBase::HorizonSectionTilePosSetup, FourierInterpol2D, EM::Expl2ImplBodyExtracter, Line2DInterSectionFinder, PreStack::AngleMute, MemCopier< T >, Seis::ParallelFSLoader3D, ArrayMath::CumArrOperExec< ArrType, SumType, OperType, RetType >, Array1DStacker< fT, ArrT >, RayTracer1D, VolProc::StatsCalculatorTask, LogCubeCreator, Convolver2D< T >, InverseDistanceArray2DInterpol, Fourier::CC::CC1D, ValueSeriesGetAll< T >, MarchingCubesSurfaceEditor, visBase::HorizonTileRenderPreparer, PreStack::TrimStatics, Array2DReSampler< T, TT >, FourierInterpol1D, PreStack::Mute, RaySynthGenerator, Array3DFloodfill< T >, DataDistributionExtracter< vT >, PreStack::Processor, MemSetter< T >, PreStack::LateralStack, EM::Horizon3DMerger, SeisZAxisStretcher, Smoother1D< T >, Smoother1D< float >, Convolver3D< T >, Stats::ParallelCalc< T >, Convolver3D< float >, Stats::ParallelCalc< float >, ZAxisTransformer, Convolver2D< T >, PreStack::AngleMuteComputer, Vel::VolumeConverter, PreStack::Stack, AGC< T >, visBase::HorizonTileResolutionTesselator, VolumeDataPackZAxisTransformer, RayTracerRunner, ReflectivitySampler, SampledExtremeFinderND< T >, ZAxisTransformPointGenerator, EM::EMObjectPosSelector, DensityCalc, BodyVolumeCalculator, ContinuousCurvatureArray2DInterpol, DPSDensityCalcND, Geometry::ArrayTesselator, BendPointFinderBase, and ImageResizer.
| void ParallelTask::quickAddToNrDone |
( |
int64_t |
loopidx | ) |
|
|
protected |
Call this from within your thread to say that you have done something, but not very often
| void ParallelTask::resetNrDone |
( |
| ) |
|
|
protected |
| static uiString ParallelTask::sPosFinished |
( |
| ) |
|
|
inlinestatic |
| virtual bool ParallelTask::stopAllOnFailure |
( |
| ) |
const |
|
inlineprotectedvirtual |
If one thread fails, should an attempt be made to stop the others? If true, enableWorkControl will be enabled, and threads should call shouldContinue() regularly.
Reimplemented in LogCubeCreator.
| static uiString ParallelTask::sTrcFinished |
( |
| ) |
|
|
inlinestatic |
| int64_t ParallelTask::totalNr |
( |
| ) |
const |
|
inlinevirtual |
| static uiString ParallelTask::tr |
( |
const char * |
text, |
|
|
const char * |
disambiguation = 0, |
|
|
int |
pluralnr = -1 |
|
) |
| |
|
inlinestaticprivate |
| friend class ParallelTaskRunner |
|
friend |
| int64_t ParallelTask::nrdonebigchunksz_ |
|
private |
| int64_t ParallelTask::totalnrcache_ |
|
private |
Public Member Functions inherited from Task
