#include "mex.hpp"
#include "mexAdapter.hpp"
#include <thread>
#include <codecvt>
class MexFunction : public matlab::mex::Function {
private:
std::future<void> voidStdFuture;
std::shared_ptr<matlab::engine::MATLABEngine> matlabPtr = getEngine();
bool isRunning = false;
public:
void ProcessSubscription()
{
matlab::data::ArrayFactory factory;
std::vector<matlab::data::Array> args;
args.push_back(factory.createScalar("test"));
for(int i = 0; i < 10; i++)
{
std::vector<matlab::data::Array> args;
args.push_back(factory.createScalar("test"));
args.push_back(factory.createScalar(i));
// std::cout << "channel = " << channel << " size= " << data.size() << std::endl;
matlabPtr->fevalAsync(u"TestSource.processSubscription", 0, std::move(args));
std::this_thread::sleep_for(std::chrono::seconds(1));
}
std::cout << "Done..." << std::endl;
}
void operator()(matlab::mex::ArgumentList outputs, matlab::mex::ArgumentList inputs) {
std::async(std::launch::async, &MexFunction::ProcessSubscription, this);
}
};
classdef testClass
methods(Static)
function out = start()
TestSource.processSubscription('test',-1);
MexThreadTest()
for i=1:10
fprintf('%f\n',TestSource.processSubscription('test'))
pause(1)
end
end
end
end
classdef TestSource
methods(Static)
function out = processSubscription(channel, data)
persistent test;
if strcmp(channel,'test') == 1
if nargin == 2
test = data;
end
out = test;
fprintf('data=%d\n',out)
else
fprintf('Unknown Message Type Received %s\n', channel);
end
end
end
end
