vs_thread.h

Go to the documentation of this file.

#ifndef _VS_THREAD_H
#define _VS_THREAD_H
 
#include <thread>
#include "revision.h"
#include "segment.h"
 
namespace vs {
 
    class thread : private std::thread {
    public:
 
        template <typename Function, typename... Args>
        explicit thread(Function&& f, Args&&... args) : std::thread(&thread::threadFunctionWrapper<Function, Args...>, this,
                          std::forward<Function>(f), std::forward<Args>(args)...) {
            auto s = std::make_shared<Segment>(Revision::currentRevision->current);
            threadRevision = std::make_shared<Revision>(Revision::currentRevision->current, s);
            Revision::currentRevision->current->Release();
            Revision::currentRevision->current = std::make_shared<Segment>(Revision::currentRevision->current);
        }
 
        void join() {
            std::thread::join();
 
            std::shared_ptr<Segment> s = threadRevision->current;
            while (s != threadRevision->root) {
                for (auto v: s->written) {
                    v->Merge(Revision::currentRevision, threadRevision, s);
                }
                s = s->parent;
            }
 
            threadRevision->current->Release();
            Revision::currentRevision->current->Collapse(Revision::currentRevision);
        }
 
        // Don't allow to detach thread
        // using std::thread::detach;
 
        using std::thread::get_id;
 
    private:
        std::shared_ptr<Revision> threadRevision;
 
        template <class Function, class... Args>
        static void threadFunctionWrapper(thread* self, Function&& f, Args&&... args) {
            Revision::currentRevision = self->threadRevision;
 
            std::invoke(std::forward<Function>(f), std::forward<Args>(args)...);
        }
 
 
    };
 
}
 
#endif