Discussion :

[Terminator]

bonjour,
je souhaite mettre dans mon programme un sorte de timeout. Je m'explique:
je lance une requete sur Yahoo à partir de mon programme mais je souhaite interrompre l'operation si cela dur plus de 5 secondes.

Comment faire exactement?
Je ne trouve pas de doc sur un eventuel TIMEOUT.

Merci d'avance

[Fifan31]

Il te faut regarder du côté de l'API conccurrent (présente à partir de Java 1.5). Tu y trouvera les callable et les future qui ont un timeout.

Je n'ai pas de solution toute faite, mais je pense que c'est une bonne piste.

[faico]

Salam,

tu peux créer un thread pour se connecter à yahoo et un deuxième thread effectuera le contrôle, et dans le premier thread tu dois garder la date de début de l'exécution !

c'est une idée ...

[orelero]

j'vais peut-etre dire une connerie mais cette méthode ne marche pas ? :

Code :

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

UrlConnection.setReadTimeout(int timeout)

(java 1.5+)

[faico]

Salam

cela peut aider : http://forum.java.sun.com/thread.jsp...sageID=9396428

[Terminator]

Merci pour toutes ces reponses.

Mais voila, je dois m'expliquer un peu mieux car vous pensez tous que je vais mettre ca pour une URL, mais je fais plutot mettre ca dans ma class principale lorsque j'appelle une "fonction" dans une autre classe.

Donc dans la classe principale j'instancie puis je lance une metthode retournant mes resultats de la requete.
En gros, ca donne

Code :

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

MesResultats = maMethodeYahoo;

Moi je souhaite interompre comme suit

Code :

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

1
2
3
4
 
Lancer Time;
MesResultats = maMethodeYahoo;
Arreter d'attendre si on depasse 5 seconde;

Bien entendu, cela n'est pas du java c'est juste pour mieux exposer mon probleme.

Merci encore pour vos reponses et j'attends vos nouvelles suggestions.

[Sanguko]

Tu peux lancer tes taches dans un thread, et utiliser la classe java.util.Timer pour implementer ton timeout.

[jibbi]

Avec un Thread
ex:

Code :

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

1
2
3
4
5
6
7
8
9
10
11
12
13
14
 
MaClass uneTache = new MaClass();
[...]
Thread th = new Thread(){
    public void run(){
              try{
            sleep(5000); // attendre 5 seconde
       }catch(Exception e){e.printStackTrace();} 
        if (uneTache.started() == false)
              uneTache.stop();
    }
}
th.start();
uneTache.start();

[Terminator]

merci

Mais je ne comprends pas des masses votre thread.

Ma méthode, je la mets où?

Code :

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

1
2
3
4
5
6
7
8
9
10
11
12
13
MaClass uneTache = new MaClass();
[...]
Thread th = new Thread(){
    public void run(){
              try{
            sleep(5000); // attendre 5 seconde
       }catch(Exception e){e.printStackTrace();} 
        if (uneTache.started() == false)
              uneTache.stop();
    }
}
th.start();
uneTache.start();

uneTache.methode, c'est elle qu'il faut surveiller.

[guis14]

pour ma part je creereai un timer et je mettrai un mouse listener sur ta JFrame et a chaque fois qu'un evenement souris se declenche, tu réinitialise ton timer. timer.restart();

Attention utilise bien le timer du package swing et pas celui du package util

après ce n'est qu'une solution parmis tant d'autre...

++

[Terminator]

Mais la souris n'est pas une bonne solution car si l'utilisateur fait une autre tache, alors ca remet à chaque fois sont timer à Zero, non?

[guis14]

non l'event listener n'est que pour ton application (JFrame ici en l'occurence) donc si l'utilisateur fait autre chose sur une autre fenetre l'event listener ne sera pas declenché

[jibbi]

Faudrait nous donner un peu de code...

[Terminator]

voila un peu de code (j'ai coupé dedans sinon ca devenait trop long):

Code :

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

1
2
3
4
5
6
7
8
9
10
11
12
13
public class YahooRequest{
 
	// Main permet de tester le class
	public static  void main (String argv [])
	{
		//Me permet juste de tester un truc, pas important le main
	}
 
	static public String[][] requete(String maRecherche) {
// J'ai effacé le code ici car pas pertinent pour vous je crois
// Juste que ca me retourne une matrice de String
	}
}

Et cette class je l'utilise comme ceci dans une autre class:

Code :

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

1
2
3
YahooRequest request = new YahooRequest();
resultats = request.requete(maRequeteATester);
// resultats est un string[][]

C'est cette derniere ligne qui pose probleme car si ca dure longtemps pour avoir un retour, je souhaite arreter cela. Je ne peux mettre le thread dans la class YahooRequest car je l'utilise aussi pour une autre class pour laquelle je ne souhaite pas de limite de temps.

MERCI ENCORE A TOUS

[Sanguko]

Code :

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

1
2
3
4
5
6
7
8
9
10
11
12
13
public class YahooRequest{
 
	// Main permet de tester le class
	public static  void main (String argv [])
	{
		//Me permet juste de tester un truc, pas important le main
	}
 
	static public String[][] requete(String maRecherche) {
// J'ai effacé le code ici car pas pertinent pour vous je crois
// Juste que ca me retourne une matrice de String
	}
}

Code :

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

1
2
3
YahooRequest request = new YahooRequest();
resultats = request.requete(maRequeteATester);
// resultats est un string[][]

Je ne sais pas si c'est une erreur de copier/coller, mais si requete est static, un simple

Code :

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

resultats = YahooRequest.requete(maRequeteATester);

suffit

Sinon, pour le principe, il faudrait quelque chose du genre

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
 
public class RequeteAvecTimeout {
        String[][] resultats ;
        String requeteATester;
 
        public RequeteAvecTimeout() {
        }
 
        public execute(String requeteATester, int timeout) {
            Thread thread = new RequeteExecuteur();
            thread.start();
            try {
               thread.join(timeout);
            } 
            catch (...) {
              ...
            }
        }
 
        class RequeteExecuteur extends Thread {
            public void run() {
                resultats = YahooRequest.requete(requeteATester);
           }
        }         
}

l'appel

Code :

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

1
2
3
YahooRequest request = new YahooRequest();
resultats = request.requete(maRequeteATester);
// resultats est un string[][]

devient alors

Code :

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

1
2
3
4
 
RequeteAvecTimeout executeur = new RequeteAvecTimeout();
executeur.execute(maRequeteATester, 5000);
resultats = executeur.resultats;

Il faudrait encore ajouter une protection sur l'acces concurrentiel à l'attribut resultats.

[jibbi]

Je vais pouvoir clarifier mon exemple et faire mieux.
Avant tout, ta méthode requete() ne devrait être static
Exécuter la fonciton main pour voir le résultat.


Code :

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
 
public class YahooRequest{
    boolean recu = false;
    boolean stop = false;
 
 
	// Main permet de tester le class
	public static  void main (String argv [])
	{
		YahooRequest request = new YahooRequest();
		request.requete("", 2000); 
 
		//Me permet juste de tester un truc, pas important le main
	}
 
	/* Est-ce qu'un tableau string[][] comme retour est vraiment nécessaire ?
	 * Les container de la librairie allège le code voir ArrayList, Vector, HashTable...
	 */
	public String[][] requete(String maRecherche, final long timeout) {		
 
    	recu = false;    	
    	System.err.print("Recherche en cours s.v.p. attendre: "+ timeout + " ms "); 
 
    	// le Thread suivant n'est pas nécessaire. Histoire d'agrémenter l'exemple :o)
    	new Thread(){
    		public synchronized void run(){    			
    			while ((!recu) && (!stop)) {    			
	    			try {    			
	    				wait(100);    			
	    			} catch (Exception e){e.printStackTrace();}
	    			System.err.print(".");
    			}
    		}
    	}.start();
 
    	// voir autre facon créer un Thread:
        Thread th = new Thread(){
        	public synchronized void run(){
        		try{        			
        			sleep(timeout);
        		}catch(Exception e){e.printStackTrace();}
 
        		if (recu == false)
        			stop = true;
        	}
        };
        th.start();                
 
 
        synchronized(this){        
        while (!stop){ 
 
        // placer le traitement ici et verifier stop periodiquement  //
 
        }
        if (stop)
        	System.err.println("\nHors delai: " +timeout + " ms depasse");
        }	
        return null;
 
	}
}

[Terminator]

Excellent,

ca fonctionne tres bien, j'ai du faire quelques arrangements, mais ca fontionne tres bien. MERCI A TOUS

[Terminator]

Je ressors ce post car apparement j'ai un souci avec ce que j'ai implementé !!

En effet, mon thread n'est pas au point, regardez plutot:

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
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
public class RequeteYahoo {
	
	boolean recu = false;
    boolean stop = false;
	// Main permet de tester le class
	public static  void main (String argv [])
	{
		String recherche = "la mer";		
		RequeteYahoo request = new RequeteYahoo();		
		String[][] s = request.requete(recherche, 200);
		
		if (s[0][0] != null)
		{
			for (int j = 0; j < s.length; j++)		
			{
				if (s[j][0] != null )
				{
					System.out.println("s :" + s[j][0]);
				}
			}
		}
		else
		{
			System.out.println("Pas de requete");
		}
	}
	

	public String[][] requete(String recherche, final long timeout) {
		recu = false;    	    
		  Thread th = new Thread(){
	        	public synchronized void run(){
	        		try{        			
	        			sleep(timeout);
	        		}catch(Exception e){e.printStackTrace();}
	        		
	        		if (recu == false)
	        			stop = true;
	        	}
	        };
	        
    	
			final int nombreResultatFixe = 10;
			String[][] tabResultat;
			tabResultat = new String[nombreResultatFixe][3];
	        SearchClient client = new SearchClient("javasdktest");
	        WebSearchRequest requete = new WebSearchRequest("\"" + recherche + "\"");
	        int nombreResultat = 0;
	   
	        try 
	        {	        	
	        	synchronized(this)
	        	{        
	                if (!stop)
	                { 
	                    th.start();
	                	WebSearchResults resultats = client.webSearch(requete);	                	                	
	            
			            // On regarde si on a assez de Resultats retournés par Yahoo (reference = nombreResultatFixe)
			            // Si pas assez, alors on prend le nombre le resultats retourné
			            // Si assez, alors on ne prend que les "nombreResultatFixe" resultats.
			            //System.out.println("Resultats retournes: " + resultats.getTotalResultsReturned());	           
			            if (resultats.getTotalResultsReturned().intValue() > 0)
			            {
				            if (nombreResultatFixe < resultats.getTotalResultsReturned().intValue())
				            {	  
				            	nombreResultat = nombreResultatFixe;
				            }
				            else
				            {
				            	nombreResultat = resultats.getTotalResultsReturned().intValue();
				            }         
				            	
			            	for (int i = 0; i < nombreResultat ; i++)	            	
				            {
				                WebSearchResult result = resultats.listResults()[i];	               
				               /* System.out.println("   " + (i + 1) + ": " + result.getTitle() + " - " +
				                        result.getUrl());*/
				                tabResultat[i][0] = result.getTitle();
				                tabResultat[i][1] = result.getUrl();
				                tabResultat[i][2] = result.getSummary();
				               
				            }
			            }
			            else 
			            {
			            	for (int i = 0; i < nombreResultat ; i++)	            	
				            {
				                tabResultat[i][0] = "" ;
				            }
			            }
	                }
	                if (stop)
	                {
	                	System.err.println("\nHors delai: " +timeout + " ms depasse");
	                	
	                }
	        	}
	        }
	        catch (IOException e) {
	            System.err.println("Error calling Yahoo! Search Service: " +
	                    e.toString());
	            e.printStackTrace(System.err);
	        }
	     
	        catch (SearchException e) {	         
	     
	            System.out.println("error!!");
	        }
	        return tabResultat;
	    }
}

C'est le code en gras que je dois surveiller. Si celui-ci depasse les 5 secondes, alors je dois arreter cette ligne et aller directement là:

Code :

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

1
2
3
4
5
  if (stop)
	                {
	                	System.err.println("\nHors delai: " +timeout + " ms depasse");
 
	                }

Je pense que mon code n'est pas au point. Pourriez-vous me corriger? J'ai essayer 2/3 trucs, mais toujours rien
D'avance merci