Ecriture fichier multithreading

Bonjour,

J'ai un programme qui calcule les nombres premier jusqu’à une valeur X (et avec un nombre de thread entré par l'utilisateur), le programme parcourt et teste chaque nombre si un nombre et premier il l'écrit dans un fichier.

Le souci est que je me retrouve des fois avec plusieurs nombre sur la même ligne.

Exemple: thread1 calcul de 0 à 10, thread2 11 à 20, et j'aurais sur une ligne 213 (le 2 du thread1 et le 13 du thread2)

Je pense que cela est du au fait que plusieurs threads écrivent en même temps dans le fichier.

Voici le code de la partie d'écriture:

Code:

---

1 2 3 4 5 6 7 8 9 10 11 12

while(n<(localDonnees->tabVal[i]) && estPremier) { if((localDonnees->tabVal[i])%n == 0) estPremier=false; n++; }   if(estPremier) { filestream << localDonnees->tabVal[i] << "\n"; //Ecriture des premiers dans un fichier }

---

J'ai aussi essayé en castant mes int en string et en leur rajoutant \n à la fin mais toujours le même problèmes.

Avez-vous une solutions pour bien les écrires les uns à la suite des autres ?

(Et accessoirement j'aimerai bien que ce soit écrit dans l'ordre croissant, et pas "random" en fonction des threads)


Merci

Tu as de bonnes intuitions: quand tu as une ressource partagée entre les threads, et qu'ils y accèdent sans ordre / protection, le comportement devient aléatoire.
Il faut un système de locks (tu as plusieurs modèles mais celui-ci conviendrait à un programme simple comme celui-là): le thread acquiert la ressource (le fichier) pour lui tout seul, écrit, puis le libère pour que les autres puissent y accéder. Il faut que tu ailles faire une petit tour sur un tuto c++ multithreadé.

Pour le tri, c'est un peu contraire à l'esprit thread: la seule solution est qu'au lieu d'accéder à un fichier, tes threads accèdent à un vecteur que tu tries ensuite avant d'écrire dans le fichier.

Le système de lock ne ferait pas perdre trop de temps ? Le but de la manœuvre est de tester la différence en temps d’exécution entre le programme multithreadé et un programme séquentiel.

J'avais déjà essayé de mettre en place un vector, qui ensuite était trié pour les écrires dans l'ordre croissant, mais j'avais une erreur lors de l'éxécution au niveau de la mémoire, je pense maintenant que cela était du à peu pres au même problème: 2threads tentaient d'écrire dans la même case du vector en même temps.

Donc si je met en place un système de lock sur le vector, je pourrais écrire les threads les uns après les autres dessus pour après le trier (mon idée première)

Mais du coup si on les écrits et donc les calcules les uns après les autres ca reviens à faire du séquentiel non ?

Edit: Je ne me suis jamais attardé sur le système de lock donc peut-être que je dit des trucs insensés

Le plus logique c'est de séparer les calculs et l'inscription dans le fichier.

De toute façon, comme l'IO est le plus lent et plus ou moins impossible à multithreader tu ne constateras des gains que sur les calculs

Merci beaucoup pour vos réponses, ca marche j'ai écrit d'abord dans des vector que j'ai lock (plus facilement que je ne le pensais au début). Puis après j'ai écrit le contenu de mes vectors dans les fichier ca marche niquel! Merci encore