Я хочу создать mex-программу, которую можно вызывать из Matlab, где пользователь может зарегистрировать функцию Matlab, которая будет использоваться для обработки.Затем программа будет использовать эту функцию для обработки данных, поступающих из другой программы в фоновом режиме.Связь между программой mex и внешней программой осуществляется через общий глобальный буфер, который я отслеживаю с помощью блокировок мьютекса.Эта часть на самом деле, кажется, работает.Проблема в том, что Matlab является однопоточным, и я хочу обрабатывать данные в фоновом режиме, чтобы пользователь мог продолжать работать с Matlab.Поскольку Matlab является однопоточным, мое решение состоит в том, чтобы создать новый поток и запустить из него движок Matlab.Для этого мне нужно вызвать движок Matlab из mex-файла, который вызывается из Matlab.Когда я пытаюсь сделать это, программа собирается нормально, но когда я пытаюсь открыть новый движок, Matlab вылетает.Используя приведенный ниже тестовый пример, если я вызываю программу (изнутри Matlab) с test('process2')
Matlab останавливается, а при использовании ctrl-c происходит сбой Matlab.Иногда кажется, что использование test('process')
работает, но сбивает Matlab, возможно, в одном из десяти вызовов.
#include "mex.h"
#include <stdio.h>
#include <string.h>
#include <pthread.h>
#include <errno.h>
#include <stdlib.h>
#include <matrix.h>
#include <unistd.h>
#include "engine.h"
void* local_process(void *arg) {
Engine *engine;
engine = engOpen(NULL);
engClose(engine);
}
void mexFunction( int nlhs, mxArray *plhs[],
int nrhs, const mxArray *prhs[]) {
if ( (nrhs<1) || (! mxIsChar(prhs[0])) ) {
mexErrMsgTxt("First argument should be a command (string)");
return;
}
/* Read command string */
int buflen = mxGetNumberOfElements(prhs[0])+1;
char* buf = mxCalloc(buflen, sizeof(char));
if (mxGetString(prhs[0], buf, buflen) != 0)
mexErrMsgTxt("Could not read command string");
mexPrintf("Command: %s\n",buf);
if (strcmp(buf,"process")==0) {
pthread_t thread;
pthread_create(&thread,NULL,local_process,NULL);
}
else if (strcmp(buf,"process2")==0) {
Engine *engine;
engine = engOpen(NULL);
engClose(engine);
}
}