demande infos threads

Version imprimable

Bonjour,

j'ai parcouru le forum, google et MSDN mais je ne trouve pas/ ne comprend pas, la gestion de plusieurs threads.

notamment l'utilsation et l'exploitation des valeurs retournées par WaitForMultipleObjects.

dans mon prog exemple j'ai ce code :

Code:

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
 
 
DWORD WINAPI NotificationProc( LPVOID lpParameter )
{
    HRESULT hr;
    HWND    hDlg = (HWND) lpParameter;
    MSG     msg;
    DWORD   dwResult;
    BOOL    bDone = FALSE;
    BOOL    bLooped;
 
    while( !bDone ) 
    { 
        dwResult = MsgWaitForMultipleObjects( 1, &g_hNotificationEvent[0], 
                                              FALSE, INFINITE, QS_ALLEVENTS );
        switch( dwResult )
        {
            case WAIT_OBJECT_0 + 0:
                // g_hNotificationEvent is signaled
 
                // This means that DirectSound just finished playing 
                // a piece of the buffer, so we need to fill the circular 
                // buffer with new sound from the wav file
                bLooped = ( IsDlgButtonChecked( hDlg, IDC_LOOP_CHECK ) == BST_CHECKED );
                if( FAILED( hr = g_pStreamingSound[0]->HandleWaveStreamNotification( bLooped ) ) )
                {
                    DXTRACE_ERR_MSGBOX( TEXT("HandleWaveStreamNotification"), hr );
                    MessageBox( hDlg, "Error handling DirectSound notifications."
                               "Sample will now exit.", "DirectSound Sample", 
                               MB_OK | MB_ICONERROR );
                    bDone = TRUE;
                }
 
                break;
 
            case WAIT_OBJECT_0 + 1:
                // Messages are available
                while( PeekMessage( &msg, NULL, 0, 0, PM_REMOVE ) ) 
                { 
                    if( msg.message == WM_QUIT )
                        bDone = TRUE;
                }
                break;
        }
    }
 
    return 0;
}

J'ai cru comprendre que pour gérer mes 3 threads dans cette même fonction je devais renplacer l'appel de waitformultipleobject par :

Code:

1
2
dwResult = MsgWaitForMultipleObjects( 3, &g_hNotificationEvent[0], 
                                              FALSE, INFINITE, QS_ALLEVENTS );

g_hNotificationEvent étant le tableau des 3 évenements crées pour les 3 threads.

je comprend bien que l'événement ce produit mais comment savoir quel threads l'a déclenché ? le 1er, le 2nd ou le dernier ?

merci d'avance, ja rame a mort avec les threads

27/05/2005, 12h57
farscape
salut,
je suppose que les events n'ont pas de rapport avec le numero de thread .

sinon au lieu de passer un handle de fenetre en arguement passe un structure qui contient le numero de thread + le handle de fenetre
dans
Code:

1 2 NotificationProc( LPVOID lpParameter )
:D

en fait je crée 3 events

Code:

1
2
3
g_hNotificationEvent[0] = CreateEvent( NULL, FALSE, FALSE, NULL );
	g_hNotificationEvent[1] = CreateEvent( NULL, FALSE, FALSE, NULL );
	g_hNotificationEvent[2] = CreateEvent( NULL, FALSE, FALSE, NULL );

et j'ai 3 threads

Code:

1
2
3
4
5
6
7
8
9
10
11
12
 
// Create a thread to handle DSound notifications
    g_hNotifyThread = CreateThread( NULL, 0, NotificationProc, 
                                    hDlg, 0, &g_dwNotifyThreadID );
 
	// Create a thread to handle DSound notifications
    g_hNotifyThread2 = CreateThread( NULL, 0, NotificationProc2, 
                                    hDlg, 0, &g_dwNotifyThreadID2 );
 
	// Create a thread to handle DSound notifications
    g_hNotifyThread3 = CreateThread( NULL, 0, NotificationProc3, 
                                    hDlg, 0, &g_dwNotifyThreadID3 );

le problème comme tu peux le voir dans la création des threads c'est que j'ai une fonction de notification par thread. Moi je cherche à n'en n'avoir qu'une seule. Ton idée est pas mal. Si je comprend bien, dans la fonction ensuite, je test le N° du thread et je répond en conséquence ?

30/05/2005, 10h16
farscape

oui
:D
30/05/2005, 10h36
inertia

MsgWaitForMultipleObjects ne permet pas de savoir à quel thread est destiné l'évenement ?

sinon la proc de notification ne dois t'elle pas respecter un format spécifique ? Dans ce cas impossible d'utiliser ta soluce.

ThreadProc dans MSDN. Apparement il est possible de passer une variable avec lpParameter mais je ne comprend pas tout.
30/05/2005, 10h39
inertia

Je viens de tilter farscape, hdlg est passé comme params dans createThread. Je lui passe la structure.

:oops: :oops: :oops:

J'ai essayé :

Code:

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
typedef struct {
 
	DWORD threadID;
	HWND  dlgHandle;
 
} threadInfos;
 
avec 
str_ThreadInfo[0].dlgHandle = hDlg;
	str_ThreadInfo[0].threadID = g_dwNotifyThreadID;
 
	// Create a thread to handle DSound notifications
    g_hNotifyThread = CreateThread( NULL, 0, MyNotificationProc, 
                                    &str_ThreadInfo[0], 0, &g_dwNotifyThreadID );
 
 
	str_ThreadInfo[1].dlgHandle = hDlg;
	str_ThreadInfo[1].threadID = g_dwNotifyThreadID2;
 
	// Create a thread to handle DSound notifications
    g_hNotifyThread2 = CreateThread( NULL, 0, MyNotificationProc, 
                                    &str_ThreadInfo[1], 0, &g_dwNotifyThreadID2 );
 
	str_ThreadInfo[2].dlgHandle = hDlg;
	str_ThreadInfo[2].threadID = g_dwNotifyThreadID3;
 
	// Create a thread to handle DSound notifications
    g_hNotifyThread3 = CreateThread( NULL, 0, MyNotificationProc, 
                                    &str_ThreadInfo[2], 0, &g_dwNotifyThreadID3 );
 
 
et 
 
threadInfos *pThreadInfo = (threadInfos *)lpParameter;

ca marche à moitié, mon premier son n'est joué qu'une fois et les autres répété mais toujours le même sample, le buffer audio n'avance pas. Les évenements crée sont dépendant des threads, j'ai l'impression que le bon threadID est récupéré mais pas le bon évenement ID

avec

Code:

1
2
dwResult = MsgWaitForMultipleObjects( 3, &g_hNotificationEvent[0], 
                                              FALSE, INFINITE, QS_ALLEVENTS );

on passe bien un pointeur vers un tableau de eventHandle ainsi que le nombre d'event (3). mais comment savoir lequel est déclenchée ? pour que je sache quel buffer sonore mettre a jour ?

si je comprend bien msgWaitForMultipleObject avec mes 3 handles :

alors

Code:

1
2
3
4
5
6
7
8
9
10
11
12
13
dwResult = MsgWaitForMultipleObjects( 3, &g_hNotificationEvent[0], 
                                              FALSE, INFINITE, QS_ALLEVENTS );
 
        switch( dwResult )
        {
            case WAIT_OBJECT_0 + 0: == event thread 1
 
            case WAIT_OBJECT_0 + 1: == event thread 2
 
            case WAIT_OBJECT_0 + 2: == event thread 3
 
            case WAIT_OBJECT_0 + 3: == ncount donc défaut
        }

non ? pourtant ce code plante a l'éxécution (mauvais rafraîchessement des mauvais buffers sonores

30/05/2005, 11h24
BertrandA

Je n'ai pas tout lu et pas tout suivi, mais tes threads accèdent-ils à des variables communes ?
Le cas échéant, as-tu géré les accès concurrentiels sur ces variables (sections critiques) ?

finalement ça marche avec :

Code:

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
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
 
DWORD WINAPI MyNotificationProc( LPVOID lpParameter )
{
    HRESULT hr;
    HWND    hDlg;
    MSG     msg;
    DWORD   dwResult;
    BOOL    bDone = FALSE;
    BOOL    bLooped;
 
    while( !bDone ) 
    { 
        dwResult = MsgWaitForMultipleObjects( 3, &g_hNotificationEvent[0], 
                                              FALSE, INFINITE, QS_ALLEVENTS );
 
		threadInfos *pThreadInfo = (threadInfos *)lpParameter;
		hDlg = pThreadInfo->dlgHandle;
 
        switch( dwResult )
        {
            case WAIT_OBJECT_0 + 0:
 
 
 
				if(pThreadInfo->threadID == 0) {
 
 
 
 
						// g_hNotificationEvent is signaled
 
						// This means that DirectSound just finished playing 
						// a piece of the buffer, so we need to fill the circular 
						// buffer with new sound from the wav file
						bLooped = ( IsDlgButtonChecked( hDlg, IDC_LOOP_CHECK ) == BST_CHECKED );
						if( FAILED( hr = g_pStreamingSound[0]->HandleWaveStreamNotification( bLooped ) ) )
						{
							DXTRACE_ERR_MSGBOX( TEXT("HandleWaveStreamNotification"), hr );
							MessageBox( hDlg, "Error handling DirectSound notifications."
									"Sample will now exit.", "DirectSound Sample", 
									MB_OK | MB_ICONERROR );
							bDone = TRUE;
						}
 
				}
 
                break;
 
			case WAIT_OBJECT_0 + 1 :
 
				if (pThreadInfo->threadID == 1) {
				bLooped = ( IsDlgButtonChecked( hDlg, IDC_LOOP_CHECK ) == BST_CHECKED );
						if( FAILED( hr = g_pStreamingSound[1]->HandleWaveStreamNotification( bLooped ) ) )
						{
							DXTRACE_ERR_MSGBOX( TEXT("HandleWaveStreamNotification"), hr );
							MessageBox( hDlg, "Error handling DirectSound notifications."
									"Sample will now exit.", "DirectSound Sample", 
									MB_OK | MB_ICONERROR );
							bDone = TRUE;
						}
				}
						break;
 
			case WAIT_OBJECT_0 + 2 :
				if(pThreadInfo->threadID == 2) {
				bLooped = ( IsDlgButtonChecked( hDlg, IDC_LOOP_CHECK ) == BST_CHECKED );
						if( FAILED( hr = g_pStreamingSound[2]->HandleWaveStreamNotification( bLooped ) ) )
						{
							DXTRACE_ERR_MSGBOX( TEXT("HandleWaveStreamNotification"), hr );
							MessageBox( hDlg, "Error handling DirectSound notifications."
									"Sample will now exit.", "DirectSound Sample", 
									MB_OK | MB_ICONERROR );
							bDone = TRUE;
						}
				}
					break;
 
 
            case WAIT_OBJECT_0 + 3:
                // Messages are available
                while( PeekMessage( &msg, NULL, 0, 0, PM_REMOVE ) ) 
                { 
                    if( msg.message == WM_QUIT )
                        bDone = TRUE;
                }
                break;
        }
    }
 
    return 0;
}

mais je note un léger décalage au bout d'un moment, ça reste léger.

j'ai noté ceci dan MSDN :

Citation:

pHandles
[in] Pointer to an array of object handles. For a list of the object types whose handles can be specified, see the following Remarks section. The array can contain handles of objects of different types. It may not contain multiple copies of the same handle.
If one of these handles is closed while the wait is still pending, the function's behavior is undefined.

The handles must have the SYNCHRONIZE access right. For more information, see Standard Access Rights

or mes threads sont créés comme suit

Code:

1
2
CreateThread( NULL, 0, MyNotificationProc, 
                                    &str_ThreadInfo[0], 0, &g_dwNotifyThreadID );

donc LPSECURITY_ATTRIBUTES est NULL, pas de synchronize. Est ce génant ?

30/05/2005, 12h16
inertia

Non ils n'accèdent pas aux même buffers audio, chacun le sient pas de conurrence à gérer

Bonjour,
je vais peut être mettre mon grain de sel à tord, mais:

Code:

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
 
         if(pThreadInfo->threadID == 0) { 
 
 
 
 
                  // g_hNotificationEvent is signaled 
 
                  // This means that DirectSound just finished playing 
                  // a piece of the buffer, so we need to fill the circular 
                  // buffer with new sound from the wav file 
                  bLooped = ( IsDlgButtonChecked( hDlg, IDC_LOOP_CHECK ) == BST_CHECKED ); 
                  if( FAILED( hr = g_pStreamingSound[0]->HandleWaveStreamNotification( bLooped ) ) ) 
                  { 
                     DXTRACE_ERR_MSGBOX( TEXT("HandleWaveStreamNotification"), hr ); 
                     MessageBox( hDlg, "Error handling DirectSound notifications." 
                           "Sample will now exit.", "DirectSound Sample", 
                           MB_OK | MB_ICONERROR ); 
                     bDone = TRUE; 
                  }

Les threadID que tu testes sont bizarres! Je n'en ai jamais vu d'aussi simple. Tu es sûr que le code marche ?

30/05/2005, 13h36
inertia
OUI

en fait, je les ais prog a la manière de microsoft dans le SDK directX :
Code:

1 2 3 DWORD g_dwNotifyThreadID = 0; HANDLE g_hNotifyThread = NULL;
100% microsoft, vérifiable dans l'exemple streamData, directSound.

Si i se gourre c'est assez grave ;)
30/05/2005, 14h46
inertia

Ce n'est pas comme ça d'habitude ?

Quelle forme alors ?
30/05/2005, 18h06
Caine
Il s'agit d'initialisation de variable, amis ça ne veut absoluement pas dire que les thread ont un id qui s'incrémente comme un entier.

Renvoie toi quelques thread id en debug pour t'en convaincre via la fonction GetCurrentThreadID.

Tiens, un liens sur msdn:
http://msdn.microsoft.com/library/default.asp?url=/library/en-us/dllproc/base/getcurrentthreadid.asp
Citation:
Envoyé par inertia

OUI

en fait, je les ais prog a la manière de microsoft dans le SDK directX :

Code:

1 2 3 DWORD g_dwNotifyThreadID = 0; HANDLE g_hNotifyThread = NULL;

100% microsoft, vérifiable dans l'exemple streamData, directSound.

Si i se gourre c'est assez grave ;)

OK, je vais contrôler tout ça. Sinon d'après le MSDN mes threads doivent être synchronizé :

Citation:

The handles must have the SYNCHRONIZE access right. For more information, see Standard Access Rights.

Sauf que je n'arrive pas à fixer cet accès de sécurité. Comment faire ? J'ai cherché dans la structure SECURITY_ATTRIBUTES que l'on passe comme 1er arg de CreateThread.
Code:

1 2 3 4 5 6 7 8 9 HANDLE CreateThread( LPSECURITY_ATTRIBUTES lpThreadAttributes, SIZE_T dwStackSize, LPTHREAD_START_ROUTINE lpStartAddress, LPVOID lpParameter, DWORD dwCreationFlags, LPDWORD lpThreadId );
Comment faire ? Ya une fonction spéciale qui prend des flags et un ID de threads en params, un truc comme ça ?

31/05/2005, 11h53
inertia

GetCurrentThreadId renvoit un DWORD (long en fait), c'est donc bien un numéric ? pas une structure bizarre comme un GUID.

J'ai des valeurs style 2038, etc etc .... donc pas 0,1,2 effectivement mes contrôles d'ID était simpliste, tout comme mes compétences actuelles en threads :wink:

Comment recup correctement l'ID d'un threads alors ? Mon problème, c'est que pour chaque threads threads, un évenement est créé. Dans mon unique fonction, comment savoir quel évenemlent a était déclenché, pour y réagir.

je pensais que c'était la valeur de retour de MsgWaitForMultipleObject ? nan.

Si je passe par plusieurs fonctions de notification de threads bien définies tout marche mais c lourd et pas propre. Ca ressemble a de la bidouille.
31/05/2005, 14h58
inertia

Pour la synchronization des threads, c'est via les access list et access entry ? ACL, ACE ?