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_;
};
 
}