Worker.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 __FWTHREAD_WORKER_HPP__
#define __FWTHREAD_WORKER_HPP__

#include <boost/any.hpp>
#include <boost/asio/io_service.hpp>
#include <future>

#include <fwCore/base.hpp>
#include <fwCore/HiResClock.hpp>

#include "fwThread/config.hpp"

namespace fwThread
{
typedef std::thread::id ThreadIdType;

FWTHREAD_API ThreadIdType getCurrentThreadId();

class Timer;

class FWTHREAD_CLASS_API Worker : public ::fwCore::BaseObject
{
public:
    typedef ::fwCore::HiResClock::HiResClockType PeriodType;
    typedef std::function< void () > TaskType;
    typedef ::boost::any ExitReturnType;

    typedef std::shared_future< ExitReturnType > FutureType;

    fwCoreClassDefinitionsWithFactoryMacro( (Worker)(::fwCore::BaseObject), (()), defaultFactory );

    Worker()
    {
    }

    FWTHREAD_API virtual void stop() = 0;

    virtual void post(TaskType handler) = 0;

    template< typename R, typename CALLABLE >
    std::shared_future< R > postTask(CALLABLE f);

    FWTHREAD_API virtual ThreadIdType getThreadId() const = 0;

    FWTHREAD_API virtual SPTR(::fwThread::Timer) createTimer() = 0;

    virtual FutureType getFuture()
    {
        return m_future;
    }

    FWTHREAD_API virtual void processTasks(PeriodType maxtime) = 0;

    FWTHREAD_API virtual void processTasks() = 0;

protected:

    FWTHREAD_API static SPTR(Worker) defaultFactory();

    Worker( const Worker& );

    Worker& operator=( const Worker& );

    FutureType m_future;
};

} //namespace fwThread

#include "fwThread/Worker.hxx"

#endif //__FWTHREAD_WORKER_HPP__