Opération read bloque le thread

Bonjour,

J'ai un programme qui a pour fonctionnalité de télécharger un fichier depuis un serveur. Le fichier est plus ou moins gros et le débit est plus ou bon (cela peut aller de quelques octets par secondes à quelques Mo par secondes.
J'ai commencé par développer un classe qui lance un Thread. Ce Thread contient toute la routine pour télécharger le fichier. Cela fonctionne très bien. Je souhaite ajouter une fonctionnalité. Cette fonctionnalité consiste à pouvoir arrêter à tout moment le téléchargement. Pour cela j'ai mis en place dans mon Thread un booléen qui est passé à true dès que je veux annuler le téléchargement. Dans ma boucle si le booléen est à true, je quitte la boucle.

Voici un exemple allégé du code :

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

import java.io.InputStream; import java.net.InetAddress; import java.net.InetSocketAddress; import java.net.Socket; import java.net.SocketAddress;   public class Download implements Runnable {   private boolean killMe = false;   @Override public void run() { String host = "http://www.domaine.com/fichier.txt"; InetAddress addr = InetAddress.getByName(host); int port = 80; SocketAddress sockaddr = new InetSocketAddress(addr, port); Socket sock = new Socket(); int timeoutMs = 5000; // 5s sock.connect(sockaddr, timeoutMs);   private byte[] buffer = new byte[32 * 1024]; InputStream input = sock.getInputStream(); do { bufferRead = input.read(buffer); } while ((bufferRead != -1) && !killMe); }   public void killMe() { killMe = true; } }

---

Ceci est le contenu simplifié de ma classe permettant de télécharger le fichier. Dans cette version, le fichier n'est pas enregistré sur le disque.

Tout se passe bien dans la majorité des cas, j'appelle la fonction killMe et le téléchargement se stoppe plus ou moins rapidement. Et c'est là où est mon problème... plus le débit est lent ou instable, plus il va être long à s’arrêter. J'ai remarqué que le programme bloqué plus facilement pendant quelques secondes voir minutes(!) sur la ligne :

Code:

---

1 2	bufferRead = input.read(buffer);

---

Cela empêche l'utilisateur de quitter le téléchargement du fichier... comment je peux améliorer cette partie ? J'ai testé le package NIO mais ça me fait exactement pareil, j'ai mal fait ?

Merci pour votre aide.

J'aurais tenter éventuellement un interrupt sur le thread en espérant que read soit "interruptable" mais maintenant j'ai des doutes...

Déjà tenté mais c'est pire, il attends la fin de la méthode run pour s’arrêter :(

Bonjour,

Les opérations de la classe SocketChannel peuvent être interrompues via un "interrupt".

Citation:

---

Envoyé par wax78

J'aurais tenter éventuellement un interrupt sur le thread en espérant que read soit "interruptable" mais maintenant j'ai des doutes...

---

L'intérêt de interrupt(), c'est que read(), entre autres, est interruptible.

Citation:

---

Envoyé par thelvin

L'intérêt de interrupt(), c'est que read(), entre autres, est interruptible.

---

Il me semblait aussi mais je n'était plus sure en fait :)

Merci, je vais essayer. J'ai trouvé également un post intéressant sur un blog concernant l'arrêt propre d'un Thread en java : http://www.roseindia.net/javatutoria..._cleanly.shtml. Si cela intéresse quelqu'un :)

Citation:

---

Envoyé par FinalSpirit

Merci, je vais essayer. J'ai trouvé également un post intéressant sur un blog concernant l'arrêt propre d'un Thread en java : http://www.roseindia.net/javatutoria..._cleanly.shtml. Si cela intéresse quelqu'un :)

---

C'est une bonne explication, en effet.
Et d'ailleurs cela m'apprend que si on construit des sockets directement avec le constructeur Socket, plutôt qu'à base de SocketChannel, elles ne sont en fait pas interruptibles. Apparemment ça n'a pas été rétrofitté pour utiliser nio par défaut. Oups, moi m'est trompé.
Je n'avais jamais remarqué.

Merci aussi à Alain qui l'a pointé du doigt au-dessus.

je ne vois pas une grande utilité de la méthode :

Code:

---

1 2 3

public void killMe() { killMe = true; }

---

il suffit de changer le contenu de la variable KillMe directement
et pour ton problème je te suggère de mettre au lieu de

Code:

---

1 2 3 4 5 6

do{ //traitement }while(condition); while(condition){ //traitement }

---

comme ça la boucle sera arrêté avant d’exécuter le traitement

Citation:

---

Envoyé par Elkorchi

je ne vois pas une grande utilité de la méthode :

Code:

---

1 2 3

public void killMe() { killMe = true; }

---

---

l'autre problème est que si killMe n'est pas volatile la réponse est aléatoire.
(de ce point de vue le billet de Heinz Kabutz est faux)