Modifier valeur d'un objet à l'intérieur d'un autre objet

Bonjour,

Dans l'une de mes méthodes qui doit renvoyer un objet de type InputStream, je déclare cet objet (inputStream) et j'instancie un thread et je souhaiterais pouvoir modifier la valeur de l'inputStream à l'intérieur de cet objet (thread).

Le problème est que si je ne déclare pas mon inputStream en final, je n'arrive pas à y avoir accès à l'intérieur de mon thread mais dans ce cas, il est final et donc par conséquence, pas modifiable puis je ne souhaite pas créer une variable de classe inputStream puisque ma classe (mapper) n'est pas composée d'un inputStream, je suis donc bloqué et mes connaissances en Java sont limitées même si j'essaie d'apprendre..

Voici ma méthode :

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 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55

private InputStream getInputStream(String url) throws MalformedURLException, IOException, NullPointerException {   final String strUrl = url; InputStream inputStream = null;   Thread thread = new Thread(){   public void run(){   Looper.prepare();   // Connexion au serveur pour communiquer avec DefaultHttpClient client = new DefaultHttpClient(); HttpConnectionParams.setConnectionTimeout(client.getParams(), 15000);   HttpResponse response; HttpEntity entity;   try{   HttpPost post = new HttpPost(strUrl);   post.setHeader("Content-Type", "application/x-www-form-urlencoded");   // Passage des parametres par le script en POST post.setEntity(new UrlEncodedFormEntity(null, HTTP.UTF_8));   // Recuperation du resultat du script response = client.execute(post);   entity = response.getEntity();   inputStream = entity.getContent();   inputStream.close();   if(entity != null){ entity.consumeContent(); }   } catch(NullPointerException e) { throw e; }catch(Exception e){ Log.e(this.getClass().getName(), "Exception à l'ajout d'une règle", e); }   Looper.loop(); } };   thread.start();   return inputStream; }

---

Si vous avez une idée, je suis preneur. :)

Réponse directe, tu peux utiliser un tableau :

Code:

---

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

public void method() { InputStream is = ... final InputStream[] tab = new InputStream[] {is};   Thread thread = new Thread() { @Override public void run() { tab[0] = new FileInputStream("file"); } } }

---

Mais attention à ton implémentation. Ta méthode à toi retourne un input stream. Aies bien conscience que lorsque la méthode va retourner, le thread n'aura sans doute pas eu le temps de démarrer, et donc ta méthode retournera null.

Je suppose que le but recherché c'est que l'appelant dispose d'un inputStream, qu'il utilisera celui là quelque part dans un futur plus ou moins proche, et que tu voudrais te garder la possibilité de paralléliser la connexion http et le reste des calculs de l'appelant.


Ce que tu propose de faire, c'est de la grosse bidouille, ça devrait être à ton appelant de se charger du parallélisme. C'est très dur à réaliser par derrière sans qu'on ne voie rien de l'appelant :/


Si tu veux quand même t'obstiner, je renverrais ma propre implémentation de InputStream, qui serait un wrapper du genre

Code:

---

1 2 3 4 5 6 7

public class FutureInputStream extends InputStream{ private Future<InputStream> future; public FutureInputStream(Future<InputStream> future) {this.future=future;} public int available(){return future.get().available();} public int read(){return future.get().read();} // etc. }

---

Code:

---

1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18

private InputStream getInputStream(String url) throws MalformedURLException, IOException, NullPointerException {   final String strUrl = url; InputStream inputStream = null;   Callable<InputStream> callable = new Callable<InputStream>{   public InputStream call(){   // ton bordel ici qui retourne un inputstream } };   FutureTask<InputStream> futureTask = new FutureTask<InputStream>(callable); new Thread(futureTask).start();   return new FutureInputStream(futureTask); }

---

Je me posais la question, savoir qui devait faire le traitement dans un autre thread, l'appelant ou directement la méthode concernée mais apparemment, c'est l'appelant.

Réellement, mon code est comme ça :

Code:

---

1 2 3 4 5 6 7 8 9 10

public List<Rules> getRules(String url){ List<Rules> listRules = new ArrayList<Rules>(); final String strUrl = url; InputStream is = null; Thread thread = new Thread(){ is = getInputStream(strUrl); }; return listRules; }

---

Code:

---

1 2 3 4 5

public InputStream getInputStream(){ ... return inputStream; }

---

Je sais que le code de la fonction getRules() n'est pas bon mais je voulais simplement montrer l'idée.

et ton getRules, il fait quoi de l'inputStream? Parce que si c'est pour le consommer tout de suite, le thread n'a aucune raison d'être.

A partir de la version 3 d'androïd, il faut obligatoirement faire passer ce qui est réseau sur un autre thread sinon ca renvoit une exception "NetworkOnMainThreadException" vu que c'est une mauvaise pratique mais effectivement, je souhaite l'utiliser immédiatement.

Ok, c'est du android, donc tu résoud pas ton problème. Pourquoi? Parce que tu va quand même attendre la fin du thread en question, et donc tu aura toujours le même problème de base pour lequel cette exception a été créée: On ne fait pas attendre le thread d'affichage non did jou :)

Ce n'est pas seulement la connection que tu doit mettre à part, c'est tout ce qui en découle. donc prend tout ta logique (rapatriement des données, traitement, mise en forme) et met le tout dans un thread à part et, à la fin de ce thread, met à jour l'affichage.

J'ai résolu mon problème en créant une méthode qui s'occupe d'exécuter mon traitement réseau dans un autre thread et de ce fait, ca me permet de le ré-exécuter autant de fois que je veux.