MREmbeddedPython.h

Go to the documentation of this file.

#pragma once
 
#include "exports.h"
 
#include <atomic>
#include <condition_variable>
#include <filesystem>
#include <functional>
#include <mutex>
#include <string>
#include <thread>
#include <vector>
 
namespace MR
{
 
 
class MREMBEDDEDPYTHON_CLASS EmbeddedPython
{
public:
    struct Config
    {
        bool siteImport{ true };
        std::string home;
        std::vector<std::string> argv;
    };
    MREMBEDDEDPYTHON_API static Config pythonConfig; 
 
    MREMBEDDEDPYTHON_API static bool isAvailable();
 
    MREMBEDDEDPYTHON_API static void shutdown();
 
    [[nodiscard]] static bool nowRunning() { return instance_().state_.load() != State::idle; }
 
    MREMBEDDEDPYTHON_API static bool runString( std::string pythonString, std::function<void( bool success )> onDoneAsync = nullptr );
 
    MREMBEDDEDPYTHON_API static bool runScript( const std::filesystem::path& path );
 
    MREMBEDDEDPYTHON_API static bool isPythonScript( const std::filesystem::path& path );
private:
    EmbeddedPython();
    EmbeddedPython( const EmbeddedPython& ) = delete;
    EmbeddedPython& operator=( const EmbeddedPython& ) = delete;
    ~EmbeddedPython();
 
    bool init_();
    void ensureInterpreterThreadIsRunning_();
 
    MREMBEDDEDPYTHON_API static EmbeddedPython& instance_();
    bool available_ = false;
    bool shutdownCalled_ = false;
 
    enum class State
    {
        idle, 
        running, 
        finishing, 
    };
 
    std::atomic<State> state_ = State::idle; 
    std::string queuedSource_;
    bool lastRunSuccessful_ = false;
    std::function<void( bool success )> onDoneAsync_;
    std::mutex cvMutex_;
    std::condition_variable cv_; 
 
 
    std::thread interpreterThread_;
 
    bool stopInterpreterThread_ = false;
};
 
}