Observer.hpp

/* ***** BEGIN LICENSE BLOCK *****
 * FW4SPL - Copyright (C) IRCAD, 2009-2017.
 * Distributed under the terms of the GNU Lesser General Public License (LGPL) as
 * published by the Free Software Foundation.
 * ****** END LICENSE BLOCK ****** */

#ifndef __FWJOBS_OBSERVER_HPP__
#define __FWJOBS_OBSERVER_HPP__

#include "fwJobs/config.hpp"
#include "fwJobs/IJob.hpp"

#include <cstdint>
#include <string>

namespace fwJobs
{

class FWJOBS_CLASS_API Observer : public IJob
{
public:
    typedef SPTR (::fwJobs::Observer) sptr;
    typedef WPTR (::fwJobs::Observer) wptr;

    typedef std::function< void (std::uint64_t) > ProgressCallback;
    FWJOBS_API static sptr New(const std::string& name, std::uint64_t workUnits = 100);

    FWJOBS_API Observer(const std::string& name, std::uint64_t workUnits = 100);

    using IJob::doneWork;
    using IJob::setTotalWorkUnits;
    using IJob::done;
    FWJOBS_API void finish();

    FWJOBS_API ProgressCallback progressCallback();

protected:

    using IJob::run;

    FWJOBS_API virtual SharedFuture runImpl();

    typedef std::packaged_task< void () > PackagedTask;

    PackagedTask m_finishTask;

};

} //namespace fwJobs

#endif //__FWJOBS_OBSERVER_HPP__