ThreadedChunkedTemperatureWorldUpdater.hpp

Go to the documentation of this file.

//
// Created by Oleg Morozenkov on 18.06.17.
//

#ifndef RECAST_THREADEDCHUNKEDTEMPERATUREWORLDUPDATER_H
#define RECAST_THREADEDCHUNKEDTEMPERATUREWORLDUPDATER_H


#include <list>
#include <queue>
#include <condition_variable>
#include <thread>
#include <future>
#include "temperature-world/interfaces/IUpdaterTemperatureWorldSemiChunkUpdatable.hpp"
#include "temperature-world/interfaces/IUpdater.hpp"
#include "temperature-world/interfaces/ITemperatureWorld.hpp"
#include "temperature-world/interfaces/ITemperatureWorldChunkable.hpp"
#include "temperature-world/interfaces/ITemperatureWorldChunkableMutable.hpp"
#include "temperature-world/interfaces/ITemperatureWorldChunkableGeneratable.hpp"
#include "temperature-world/interfaces/ITemperatureWorldChunkableObservable.hpp"
#include "temperature-world/interfaces/ITimer.hpp"
#include "temperature-world/interfaces/ITimerBlockable.hpp"

class ThreadedChunkedTemperatureWorldUpdater : public virtual IUpdater {
public:
    ThreadedChunkedTemperatureWorldUpdater(
            std::shared_ptr<ITemperatureWorldChunkableObservable<ITemperatureWorldChunkableGeneratable<ITemperatureWorldChunkableMutable<ITemperatureWorldChunkable<ITemperatureWorld>>>>> world,
            std::function<std::shared_ptr<IUpdaterTemperatureWorldSemiChunkUpdatable<IUpdater>>(std::shared_ptr<ITemperatureWorldBoundable<ITemperatureWorld>>)> makeChunkUpdaterFn);

    ~ThreadedChunkedTemperatureWorldUpdater();

    void update() override;

protected:
    struct ThreadData {
    public:
        std::shared_ptr<ITemperatureWorldChunkableObservable<ITemperatureWorldChunkableGeneratable<ITemperatureWorldChunkableMutable<ITemperatureWorldChunkable<ITemperatureWorld>>>>> world;
        std::function<std::shared_ptr<IUpdaterTemperatureWorldSemiChunkUpdatable<IUpdater>>(std::shared_ptr<ITemperatureWorldBoundable<ITemperatureWorld>>)> makeChunkUpdaterFn;

        std::atomic<bool> isRunning;
        std::vector<std::thread> workers;

        std::vector<std::shared_ptr<IUpdaterTemperatureWorldSemiChunkUpdatable<IUpdater>>> updaters;
        std::mutex updatersMutex;

        std::vector<std::future<void>> tasks;
        std::queue<std::pair<std::shared_ptr<IUpdater>, std::promise<void>>> tasksQueue;
        std::mutex tasksQueueMutex;
        std::condition_variable tasksQueueWait;
        std::mutex tasksQueueWaitMutex;
    };

    static void _work(std::shared_ptr<ThreadData> data);
    static void _watchChunk(std::shared_ptr<ThreadData> data, std::shared_ptr<ITemperatureWorldBoundable<ITemperatureWorld>> chunk);

    std::shared_ptr<ThreadData> _data;
};


#endif //RECAST_THREADEDCHUNKEDTEMPERATUREWORLDUPDATER_H