MRParallelProgressReporter.h

Go to the documentation of this file.

#pragma once
#include "MRMeshFwd.h"
#include <MRPch/MRBindingMacros.h>
#include <forward_list>
#include <atomic>
#include <thread>
#include <mutex>
 
 
namespace MR
{
 
class MR_BIND_IGNORE ParallelProgressReporter
{
public:
    MRMESH_API ParallelProgressReporter( const ProgressCallback& cb );
 
    struct TaskInfo
    {
        float progress = 0.f;
        float weight = 1.f;
    };
 
    struct PerTaskReporter
    {
        MRMESH_API bool operator()( float p ) const;
        ParallelProgressReporter* reporter_ = nullptr;
        TaskInfo* task_ = nullptr;
    };
 
 
    MRMESH_API PerTaskReporter newTask( float weight = 1.f );
 
    MRMESH_API bool operator()();
 
private:
    bool updateTask_( float delta );
 
    const ProgressCallback& cb_;
 
    std::forward_list<TaskInfo> perTaskInfo_;
 
    float totalWeight_ = 0;
 
    float progress_ = 0;
 
    bool continue_ = true;
 
    std::mutex mutex_;
 
    std::thread::id mainThreadId_;
};
 
}