pThread passage argument normal

Version imprimable

Bonjour.

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

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
  // 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 ?

13/01/2012, 17h25
therwald
je dirais que ta structure d'info devrait contenir un std::vector<Chunk>.
Code:

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.
13/01/2012, 17h43
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.
13/01/2012, 17h50
therwald

Arf! J'avais oublié ce problème :traine:
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?
13/01/2012, 18h03
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.

en quoi c'est compliqué de faire:
Code:

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?

14/01/2012, 18h49
jerem3000

Ce n'est pas difficile effectivement, je penser juste que j'avais un problème de cast ou une chose dans le genre.

En tous cas c'est parfait cela marche parfaitement, merci.

Sujet résolu.