#include <ored/utilities/progressbar.hpp>

Inheritance diagram for MultiThreadedProgressIndicator:

Collaboration diagram for MultiThreadedProgressIndicator:

Public Member Functions
	MultiThreadedProgressIndicator (const std::set< QuantLib::ext::shared_ptr< ProgressIndicator > > &indicators)

void	updateProgress (const unsigned long progress, const unsigned long total, const std::string &detail) override

void	reset () override

Public Member Functions inherited from ProgressIndicator
	ProgressIndicator ()

virtual	~ProgressIndicator ()

virtual void	updateProgress (const unsigned long progress, const unsigned long total, const std::string &detail)=0

virtual void	reset ()=0

Private Attributes
boost::shared_mutex	mutex_

std::set< QuantLib::ext::shared_ptr< ProgressIndicator > >	indicators_

std::map< std::thread::id, std::tuple< unsigned long, unsigned long, std::string > >	threadData_

Detailed Description

Progress Manager that consolidates updates from multiple threads

Definition at line 130 of file progressbar.hpp.

Constructor & Destructor Documentation

◆ MultiThreadedProgressIndicator()

MultiThreadedProgressIndicator ( const std::set< QuantLib::ext::shared_ptr< ProgressIndicator > > & indicators )

explicit

Definition at line 114 of file progressbar.cpp.

116 : indicators_(indicators) {}

ore::data::MultiThreadedProgressIndicator::indicators_

std::set< QuantLib::ext::shared_ptr< ProgressIndicator > > indicators_

Definition: progressbar.hpp:138

Member Function Documentation

◆ updateProgress()

void updateProgress	(	const unsigned long	progress,
		const unsigned long	total,
		const std::string &	detail
	)

overridevirtual

Implements ProgressIndicator.

Definition at line 118 of file progressbar.cpp.

                                                                                                                                    {
    boost::unique_lock<boost::shared_mutex> lock(mutex_);
    threadData_[std::this_thread::get_id()] = std::make_tuple(progress, total, detail);
    unsigned long progressTmp = 0;
    unsigned long totalTmp = 0;
    std::ostringstream detailTmp;
    for (auto const& d : threadData_) {
        progressTmp += std::get<0>(d.second);
        totalTmp += std::get<1>(d.second);
 
        if (detailTmp.tellp() != 0)
            detailTmp << "|";
        detailTmp << std::get<2>(d.second);
    }
    for (auto& i : indicators_)
        i->updateProgress(progressTmp, totalTmp, detailTmp.str());
}

◆ reset()

void reset ( )

overridevirtual

Implements ProgressIndicator.

Definition at line 136 of file progressbar.cpp.

                                           {
    boost::unique_lock<boost::shared_mutex> lock(mutex_);
    for (auto& i : indicators_)
        i->reset();
    threadData_.clear();
}

Member Data Documentation

◆ mutex_

boost::shared_mutex mutex_

mutableprivate

Definition at line 137 of file progressbar.hpp.

◆ indicators_

std::set<QuantLib::ext::shared_ptr<ProgressIndicator> > indicators_

private

Definition at line 138 of file progressbar.hpp.

◆ threadData_

std::map<std::thread::id, std::tuple<unsigned long, unsigned long, std::string> > threadData_