Discussion :

[yoann1989]

Bonjour tout le monde,

Cela fait maintenant un petit moment que j'essaie de créer un fichier mex-file qui utilise le multi-threading mais en vain.

En fait j'arrive à lancer un thread supplémentaire comme dans le premier exemple de ce lien : http://www.mathworks.fr/support/solu.../data/1-V3B5T/

Mais lorsque je veux suivre la même procédure pour exécuter non pas un mais deux thread (par exemple pour incrémenter deux compteurs au lieu d'un seul) cela ne fonctionne pas (soit le second thread lance retourne n'importe quoi soit matlab se fige ).

Si quelqu'un sait comment remédier à ce problème, je suis preneur.

Je vous remercie d'avance.

[Jerome Briot]

Je ne connais pas bien cette API, donc la réponse suivante est à prendre avec précaution

Code C :

Sélectionner tout - Visualiser dans une fenêtre à part

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
#include "mex.h"
#include <windows.h>
#include <stdio.h>
#include <process.h>
 
unsigned Counter1, Counter2; 
 
unsigned __stdcall count1( void* pArguments )
{
    while ( Counter1 < 500000 )
        Counter1++;
 
    _endthreadex( 0 );
    return 0;
} 
 
unsigned __stdcall count2( void* pArguments )
{
    while ( Counter2 < 1000000 )
        Counter2++;
 
    _endthreadex( 0 );
    return 0;
} 
 
void mexFunction( int nlhs, mxArray *plhs[], 
		  int nrhs, const mxArray*prhs[] )
 
{ 
    HANDLE hThread[2];
    unsigned threadID1, threadID2;
 
    hThread[0] = (HANDLE)_beginthreadex( NULL, 0, &count1, NULL, 0, &threadID1 );
    hThread[1] = (HANDLE)_beginthreadex( NULL, 0, &count2, NULL, 0, &threadID2 );
 
    WaitForMultipleObjects(2, hThread, TRUE, INFINITE );
 
    printf( "Counter1 should be 500000; it is-> %d\n", Counter1 );
    printf( "Counter2 should be 1000000; it is-> %d\n", Counter2 );
 
    CloseHandle( hThread[0] );
    CloseHandle( hThread[1] );
 
    return;
}

[yoann1989]

Merci Dut pour ta réponse si rapide.

C'est ce que j'ai fait, la compilation se passe sans embûche mais lorsque je lance le programme, Matlab se fige. Je ne suis pas devant mon ordinateur donc je ne peux pas t'envoyer le code que j'ai rédigé mais je te le ferai parvenir dans la soirée.

Encore merci

[Jerome Briot]

C'est ce que j'ai fait, la compilation se passe sans embûche mais lorsque je lance le programme, Matlab se fige.

Tu parles de ton code ou du mien ?

[yoann1989]

je n'ai pas testé ton code mais il est quasiment identique au mien mis à part la récupération de deux chaines de caractères en entrée permettant de mettre une condition dans le remplissage des compteurs.

[yoann1989]

Voilà la fonction que j'ai codée, elle se rapproche grandement de ce que tu as fait :

Code C :

Sélectionner tout - Visualiser dans une fenêtre à part

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
 
#include "mex.h"
#include <windows.h>
#include <stdio.h>
#include <process.h>
#include <string.h>
 
unsigned Counter = 0;
unsigned Counter_1 = 0;
 
unsigned __stdcall SecondThreadFunc( void* pArguments )
{
    if( strcmp( (char*)pArguments,"Init" ) )
        Counter = 12;
    else
    {
        while ( Counter < 1000000 )
        Counter++;
    }
 
    _endthreadex(0);
    return 0;
}
 
unsigned __stdcall ThirdThreadFunc( void* pArguments )
{
    if( strcmp( (char*)pArguments,"Init" ) )
        Counter_1 = 12;
    else
    {
        while ( Counter < 1000000 )
        Counter_1++;
    }
 
    _endthreadex(0);
    return 0;
}
 
void mexFunction( int nlhs, mxArray *plhs[], int nrhs, const mxArray *prhs[] )
{
    HANDLE hThreads[2];
    unsigned threadID[2];
    char *cmd;
    char *cmd1;
 
    //On vérifie que l'argument soit une chaîne de caractères
    if( nrhs != 2 )
        mexErrMsgTxt( "Two input required" );
    if( !mxArrayToString( prhs[0] ) )
        mexErrMsgTxt( "Input must be a string" );
 
    //On récupère la chaîne de caractères
    cmd = mxArrayToString( prhs[0] );
    cmd1 = mxArrayToString( prhs[1] );
 
    printf( "Creating second thread...\n" );
 
    //Create the second thread.
    //Create the third thread.
    hThreads[0] = (HANDLE)_beginthreadex( NULL, 0, &SecondThreadFunc, cmd, 0, &threadID[0] );
    hThreads[1] = (HANDLE)_beginthreadex( NULL, 0, &ThirdThreadFunc, cmd1, 0, &threadID[1] );
 
    WaitForMultipleObjects(2,hThreads,TRUE,INFINITE);
    printf( "Counters should be 1000000; first is -> %d\n", Counter );
    printf( "Counters should be 1000000; first is -> %d\n", Counter_1 );
 
    CloseHandle( hThreads[0] );
    CloseHandle( hThreads[1] );
 
    mxFree(cmd);
    mxFree(cmd1);
}

[Invité]

Bonjour,

Une petite erreur d'étourderie ligne 31 :

Code C :

Sélectionner tout - Visualiser dans une fenêtre à part

while ( Counter_1 < 1000000 )

[yoann1989]

Ouch, j'ai relu le code 5000 fois et je ne l'ai pas vu... Mille merci, cela ne peut venir que de là... Encore merci... Je suis vraiment un boulet