Discussion :

[LePapat26]

Bonjour à tous,

je travaille sous WinXPSP3 / MS Visual Studio Express Edition 2008 / langage C.

J'ai créé un pointeur *pTab sur un tableau de structure FLOW_UNIT_s de taille N.
La structure FLOW_UNIT_s est décrite ci - dessous.

Code :

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

1
2
3
4
5
6
typedef struct FLOW_UNIT_s{
	time_t	tF;				
	int inc;				
	int cnt;				
	double volt;			
}FLOW_UNIT_s;

La zone mémoire pointée par *pTab est actualisée en temps réel par un thread1. Le thread1 écrit dans *pTab, attend 40 ms, écrit dans *p(Tab+1), attend 40 ms, .... jusqu'à *p(Tab+N-1).

Quand on arrive au Nième élément, un autre thread2 doit faire une copie de ce qui est contenu à l'instant t dans la zone mémoire pointée par *pTab (pendant ce temps, le thread1 continue à faire son travail, c'est à dire commence à écraser *pTab, *(pTab+1), ...).

Ma question est la suivante : comment puis-je faire une copie du contenu de la zone mémoire pointée par *pTab à un instant donné dans une variable temporaire alors que le thread1 continue sa mise à jour ?

J'ai défini un nouveau pointeur *pTab_temp = *pTab. Mais forcément la copie est actualisée en même temps que *pTab.

Je suis preneur des idées que cette discussion vous inspirera.

Merci d'avance.
LePapat

[ram-0000]

Tu as 2 thread qui tentent d'accèder à la même zone mémoire simultanément, un pour écrire, un pour lire.

Je pense qu'il faut établir une section critique pour protéger ta zone mémoire.

Sous Microsoft, regarde CRITICAL_SECTION et sous Linux, regarde semget()

Un petit tuto sous Linux ici

[nicolas.sitbon]

Tu as 2 thread qui tentent d'accèder à la même zone mémoire simultanément, un pour écrire, un pour lire.

Je pense qu'il faut établir une section critique pour protéger ta zone mémoire.

Sous Microsoft, regarde CRITICAL_SECTION et sous Linux, regarde semget()

Un petit tuto sous Linux ici

Non les sémaphores ne sont pas adaptés dans ce cas là, je verrais plutôt un mutex ou mieux, puisqu'il est question de multithread, utiliser les read write locks.

[Mac LAK]

Pour ma part, je rendrais global (ou partagé si l'on parle de multi-processus) un tableau de "FLOW_UNIT_s*", protégé par un mutex attaché à ce tableau.

Ensuite, la production / consommation se fait simplement en mettant à jour le pointeur d'une structure FLOW_UNIT_s dans le tableau, avec contrôle de mutex. Comme les données sont séparées (les threads n'utilisent pas les structures des petits copains), il n'y a pas de risque.

Via par exemple InterlockedExchange ou autre fonction similaire, il n'y a carrément plus besoin de mutex sur le tableau...

Ajout d'une structure :

• Acquisition de la donnée.
• Allocation d'une structure (malloc), et copie des données dedans.
• Prise du mutex de tableau.
• Recherche d'une case vide, ou ajout en "queue", au choix.
• Mise à jour du tableau avec l'adresse de la structure allouée.
• Libération du mutex.

Retrait / consommation d'une structure :

• Prise du mutex de tableau.
• Rechercher de la première cellule non-vide.
• Copie du pointeur dans le thread.
• Positionnement de la cellule de tableau à NULL.
• Libération du mutex.
• Travail sur la structure.
• Libération de la structure (free).

Simple, efficace, et difficile de faire moins lourd... Si en plus le tableau est "circulaire" (solution préférable), et que l'on a accès aux fonctions Interlocked, alors il n'y a plus de mutex ni quoi que ce soit d'autre et on obtient en plus des performances maximales.

[LePapat26]

Merci pour vos retours tres instructifs.

J'ai opte pour l'option mutex. Ca faisait un moment que je voulais la mettre en oeuvre.

J'ai donc englobe mon tableau de structure FLOW_UNIT_s et un mutex dans une nouvelle structure :

Code :

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

1
2
3
4
typedef struct NEW_STRUCT_s{		
	FLOW_UNIT_s flow[N];
	pthread_mutex_t mutex_flow;		
}NEW_STRUCT_s;

mon pointeur *pTab pointe sur cette New structure. Les threads 1 & 2 fait toujours leur business mais le thread de copie est plus elabore avec pthread_mutex_lock/unlock quand je veux faire ma photo a l'instant t.

J'ai une derniere question a propos du conseil de Mac Lak

un tableau de "FLOW_UNIT_s*", protégé par un mutex attaché à ce tableau.

En fait cette structure NEW_STRUCT_s contient d'autres champs qui sont modifies par d'autres threads. Est - il possible d'attacher le mutex uniquement au tableau de FLOW_UNIT_s et non a toute la structure NEW_STRUCT_S ?

Merci d'avance.

lePapat

[Mac LAK]

Est - il possible d'attacher le mutex uniquement au tableau de FLOW_UNIT_s et non a toute la structure NEW_STRUCT_S ?

Quand on parle "d'attacher" un mutex à une entité, cela veut dire que l'on protège tout accès à cette entité par la prise / libération du mutex... Ce n'est donc en aucune façon automatique, et tu peux "attacher" un mutex à n'importe quoi... Y compris uniquement au 12ème bit du 4ème entier de ta structure si ça t'est nécessaire.