Discussion :

[Anonymouse]

Bonjour

Je cherche à tuer un thread java malgré le fait que celui-ci soit bloqué sur une opération d'E/S (Lecture dans un flux d'entrée). J'ai trouvé beaucoup de réponses sur le sujet mais aucune qui me convienne.
Pour le moment j'ai redéfinit la méthode interrupt() pour qu'elle ferme le flux d'entrée. Malheureusement mon programme se fige après être entré dans la méthode interrupt() (Si vous regardez le code il affiche la string"avant" mais pas "apres").
Pour le moment je ne vois aucune solution simple qui me permette de tuer le thread.
Qualqu'un aurait-il une idée??

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
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
 
	public void run()
	{
		try
		{
			this.priseClient=new Socket(this.adresseIp,2007);
 
			this.fluxOut=new PrintWriter(this.priseClient.getOutputStream());
 
			this.fluxIn=new BufferedReader(new InputStreamReader(this.priseClient.getInputStream()));
 
			while(true)
			{
				String messageServeur="";
 
				if(ModeleClient.interrupted())
				{
					return;
				}
				//Méthode bloquante qui lit les les envois du serveur (rencoi null si rien n'est lu)
				messageServeur=this.fluxIn.readLine();
 
				//si rien n'est lut car le flux est fermé
				if(messageServeur==null)
				{
					return;
				}
				//si le serveur envoie un message
				else if(messageServeur.length()>0)
				{	
					//on met à jour le forum de l'IHM
					this.fireForumChanged(messageServeur);
				}
			}
		}
 
		catch (IOException e)
		{
			e.printStackTrace();
			this.fireMessageErreur(e.getMessage());
		}
		finally
		{	
			this.fluxOut.close();
			try
			{
				this.fluxIn.close();
			}
			catch (IOException e)
			{			
				e.printStackTrace();
			}
		}
	}
	public void interrupt()
	{
		super.interrupt();
		try
		{
			System.out.println("avant");
			this.fluxIn.close();
			System.out.println("apres");
		}
		catch (IOException e)
		{
			e.printStackTrace();
		}
	}
 
	public void Deconnecter()
	{
		this.interrupt();
	}

Merci d'avance de vos réponses

[DevTeam_]

Bonjour

Je cherche à tuer un thread java malgré le f

Dommage, ça avait l'air intéressant !

[Anonymouse]

Dommage, ça avait l'air intéressant !

Touche tab + Entrer

[T`lash]

Que se passe-t-il si tu mets super.interrupt() à la fin de ta méthode surchargée ?

[gifffftane]

Je cherche à tuer un thread java malgré le fait que celui-ci soit bloqué sur une opération d'E/S (Lecture dans un flux d'entrée). J'ai trouvé beaucoup de réponses sur le sujet mais aucune qui me convienne.

Ben dit-donc. Et qu'ont ces méthodes qui ne te convienne pas ??

[Anonymouse]

Que se passe-t-il si tu mets super.interrupt() à la fin de ta méthode surchargée ?

Ca reste bloqué tout pareil

Ben dit-donc. Et qu'ont ces méthodes qui ne te convienne pas ??

Bah la plupart proposent l'interruption par un flag donc ça ne peut marcher.
J'ai vu aussi des liens qui proposent d'appliquer la méthode close() sur le socket pour générer une I/O Exception mais bon de un je trouve ça pas très classe de deux je ne peux pas différencier une "véritable IOexception" (Cad non attendue) d'une Exception déclenchée par l'appel à la méthode close.

[gifffftane]

Mais si le thread est bloqué sur une opération d'entrée / sortie, il est normal de sortir en erreur, non ?... et donc de passer par un close et une IOException ?

[Anonymouse]

Mais si le thread est bloqué sur une opération d'entrée / sortie, il est normal de sortir en erreur, non ?... et donc de passer par un close et une IOException ?

Ben si c'est l'utilisateur de l'application qui demande au thread de se fermer il va se prendre le même message d'erreur que si le thread se ferme inopinément.

[gifffftane]

Je comprends bien, mais il me semblait que l'hypothèse de base était un thread bloqué par accident.

S'il apparaît que l'utilisateur, de façon normale, peut arrêter la conversation, et si tu t'intéresses à faire les choses dans les règles de l'art - même si le coup du close() est très usité - alors il faut changer ton fusil d'épaule et travailler avec les channels et nio.

Tu trouveras plein de choses intéressantes sur le sujet à How to Stop a Thread or a Task, pour toi bien entendu au niveau du chapitre Blocking I/O, mais pas seulement.