[MT] Surveillance de périodicité
Bonjour,
Je souhaite effectuer une surveillance de périodicité d'évènements.
Chaque évènement a une périodicité qui lui est propre (de 2 à 5 secondes).
Une centaine d'événements différents sont détectés.
Je souhaite donc implémenter une centaine de processus légers (même très légers), qui attendent un événement toutes les 2 à 5 secondes.
Si, au bout d'un TimeOut l'événement n'est pas apparu, un signal est émis.
En implémentant le code si dessous, l'application est très gourmande en ressources.
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
| void init_Surveillance()
{
int i ;
// Initialisation des structures de paramères de Threads
ParamThread_Surveillance[0].iPeriode=1000 ;
ParamThread_Surveillance[0].ulIdent=30 ;
ParamThread_Surveillance[0].iTimeOut=3400 ;
ParamThread_Surveillance[1].iPeriode=4000 ;
ParamThread_Surveillance[1].ulIdent=32 ;
ParamThread_Surveillance[1].iTimeOut=5500 ;
for(i=2;i<80;i++)
{
ParamThread_Surveillance[i].iPeriode=2000 ;
ParamThread_Surveillance[i].ulIdent=i ;
}
// Démarrage des Threads de surveillance
for(i=0 ; i<80 ; i++)
{
hSurvThread[i]=AfxBeginThread(Surveillance_Thread, (void*) &ParamThread_Surveillance[i], THREAD_PRIORITY_TIME_CRITICAL,0,0,0);
}
} |
Code:
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
| UINT Surveillance_Thread(LPVOID context)
{
struct_ParamThread_Surveillance* pParam=(struct_ParamThread_Surveillance*)context ;
DWORD ret;
HANDLE* Hdl=pParam->InterruptEvents ;
int iTimeOut =pParam->iTimeOut ;
for(;;) // Boucle infinie
{
ret = WaitForMultipleObjects(2, Hdl, FALSE,iTimeOut );
if(ret==WAIT_TIMEOUT)
{
//on a un TimeOut
ErrorSignal(pParam->ulIdent) ;
}
}
return 0 ;
} |
Y a-t-il des objets moins gourmands en ressources que les AfxThread ?
L'utilisation de micro-threads est elle bien adaptée à ce type de problème ?
Merci d'avance pour vos avis.
Nicolas
Strasbourg
