Discussion :

[jerem3000]

Bonjour.

Dans mon application j'utilise des thread et je passe comme argument une structure.

Code :

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
  // Création de la structure de base
    struct thread_data info;
    info.distFile = Downloader::distFile;
    info.file = Downloader::file;
    info.hebergeur = Downloader::hebergeur;
    info.localFile = localFile;
    info.URL = URL;
 
	info.startLength = 0; // Emplacement de commencement
	info.downloadLength = 0; // Taille a télécharger
 
    // Récupérer taille fichier
	Downloader::getLengthFile();
	info.lengthFile = Downloader::lengthFile;
 
 
	// Crée le nombre de thread nécessaire
    pthread_t *threads;
    threads = (pthread_t*) malloc( sizeof(pthread_t) * nbThread );
 
 
	int quant = Downloader::lengthFile / nbThread;
 
	int x= 0;
	for(int i = 0 ; i < nbThread ; i++)
	{
		info.startLength = x; // Emplacement de commencement
		info.downloadLength = quant; // Taille a télécharger
		x += quant;
		pthread_create(&threads[i], NULL, DownloadeThread, (void *)&info);
	}

Je récupère les donnée depuis mon thread mais comme cela est un pointeur et que les donnée change a chaque lancement de thread dans la boucle, je récupère sur chaque les donnée du dernier lancement.

Comment puis-je régler ce problème ?

[therwald]

je dirais que ta structure d'info devrait contenir un std::vector<Chunk>.

Code :

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

1
2
3
4
5
6
 
class Chunk{
int startPoint;
int quant;
thread_data* backptr;
}

A chaque fois que tu crée une thread, tu push_back un objet chunk dans ton vector, et c'est l'adresse chunks[i] que tu passes à ta thread. (le back_ptr permet à la thread de remonter vers les infos globales).

Par contre, sur ton calcul de quant attention, il me semble que tu risque de ne pas télécharger tout le fichier par erreur d'arrondi.

[JolyLoic]

Attention, ajouter un élément dans un vecteur invalide les itérateurs et pointeurs existants sur les éléments déjà présent. Donc si on ne fait pas attention, créer ainsi un nouveau thread peut casser les autres en cours d'exécution.

[therwald]

Arf! J'avais oublié ce problème
Donc il faudrait plutôt faire un resize une fois le nombre de thread calculé (avant la boucle) et dans la boucle mettre à jour le contenu de l'objet chunks[i] puis passer son adresse à la thread créée. Avec ça les pointeurs resteraient valides, non?

[jerem3000]

Merci pour vos réponses.

Moi qui penser qu'il n'y avait pas grand choses à faire au vu du peu de choses que j'ai besoin de faire ^^

N'y a-t-il pas de solution plus simple a mettre en place?

Concernant la variable quant je suis au courant, mais pas de problème car sur le dernier thread je ne spécifie pas le nombre de byte à récupérer mais juste là où il commence et donc il le télécharge entièrement.

[therwald]

en quoi c'est compliqué de faire:

Code :

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

1
2
3
4
5
6
 
1 info.chunks.resize(nbThread);
...
2 info.chunks[i]->startLength=x; //(simple modification d'une ligne préexistante)
3 info.chunks[i]->downloadLength=quant; //(simple modification d'une ligne préexistante)
4 info.chunks[i]->back_ptr=&info;

avec un malheureux petit objet Chunk à 3 membres et un vector dans info?