ActiveWorkers.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 __FWSERVICES_REGISTRY_ACTIVEWORKERS_HPP__
#define __FWSERVICES_REGISTRY_ACTIVEWORKERS_HPP__

#include "fwServices/config.hpp"

#include <fwCore/mt/types.hpp>

#include <fwThread/Worker.hpp>

namespace fwServices
{
namespace registry
{

class FWSERVICES_CLASS_API ActiveWorkers : public ::fwCore::BaseObject
{

public:

    fwCoreClassDefinitionsWithFactoryMacro((ActiveWorkers)(::fwCore::BaseObject),
                                           (()),
                                           std::make_shared< ActiveWorkers >);

    typedef std::string WorkerKeyType;

    typedef std::map< WorkerKeyType, ::fwThread::Worker::sptr > WorkerMapType;

    FWSERVICES_API static const std::string s_DEFAULT_WORKER;

    FWSERVICES_API ActiveWorkers();

    FWSERVICES_API virtual ~ActiveWorkers();

    FWSERVICES_API ::fwThread::Worker::sptr getWorker( const WorkerKeyType& key ) const;

    FWSERVICES_API static void setDefaultWorker( ::fwThread::Worker::sptr worker );

    static FWSERVICES_API ::fwThread::Worker::sptr getDefaultWorker();

    FWSERVICES_API void addWorker( const WorkerKeyType& key, ::fwThread::Worker::sptr worker );

    FWSERVICES_API void initRegistry();

    FWSERVICES_API void clearRegistry();

    FWSERVICES_API static ActiveWorkers::sptr getDefault();

protected:

    WorkerMapType m_workers;

    mutable ::fwCore::mt::ReadWriteMutex m_registryMutex;

    static ActiveWorkers::sptr s_currentActiveWorkers;

};

} // namespace registry
} // namespace fwServices

#endif // __FWSERVICES_REGISTRY_ACTIVEWORKERS_HPP__