Discussion :

[cecile38]

Bonjour,

J'ai une application contenant plusieurs threads. J'ai une partie de mon code qui est executée par l'ensemble de mes threads mais pas en parallèle. Cela me fait perdre beaucoup en performance donc j'aurais aimé savoir si c'était possible de paralléliser cette partie. Voici le bout de code en question :

Code :

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

1
2
3
4
5
6
7
 
reader = new BufferedReader(new InputStreamReader(conn.getInputStream()));
String ligne;
 
while ((ligne = reader.readLine()) != null) {
response.append(ligne);
}

Merci d'avance pour votre aide

[adiGuba]

Salut,



C'est à dire ? Tu pourrais être plus précis ?

Tu voudrais copier un même fichier via plusieurs threads ? rien que les mécanismes de synchronisation pourrait s'avérer beaucoup plus lourd


a++

[cecile38]

Non en fait j'ai plusieurs threads qui effectuent une connection et récupèrent des données. Le problème est que quand le code s'execute tous les threads font leurs traitements en parallèle sauf la partie que j'ai mise plus haut qui a l'air d'être synchronisée. Du coup, les threads récupèrent leurs données à tour de rôle alors qu'il utilisent des objets "conn" différents donc je ne vois pas la nécessité : cela fait perdre beaucoup de temps.

J'aurais voulu savoir s'il y avait une autre façon d'écrire ce code afin qu'il puisse etre executé en parallèle par tous mes threads.

[GPPro]

Il faut aussi que ta source de données supporte les accès en parallèle et qu'il n'y ait pas de bottleneck technique (du genre ta source est une base de données qui accède à un disque qui lui a un débit limité).

[cecile38]

Non ma source de données accepte bien les requetes en parallèle donc j'ai l'impression que ça vient du code mais je vois pas bien quoi...

[cecile38]

Je peux me tromper mais je crois que la méthode getInputStream est "synchronized".

Serait-ce possible d'utiliser une méthode équivalente qui ne le soit pas?

[GPPro]

Quelle est ta source de données ? S'il s'agit d'une socket getInputStream est effectivement synchronisée (au moins dans l'implémentation par défaut).

De façon générale : je vois mal comment tu pourrais récupérer un InputStream différent à partir d'une même source. Comment serait consommée les données ?

N'y aurait-il pas un problème de conception de ton code ? D'abord tu devrais avoir un lecteur qui consomme les data et ensuite les dispatch aux threads devant faire le boulot.