Mettre au point un TIMEOUT

Version imprimable

14/04/2007, 16h12
Terminator

Mettre au point un TIMEOUT

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
14/04/2007, 17h02
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. :oops:
14/04/2007, 17h10
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 ...
14/04/2007, 17h14
orelero

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

Code:

UrlConnection.setReadTimeout(int timeout)

(java 1.5+)
14/04/2007, 19h12
faico

Salam

cela peut aider : http://forum.java.sun.com/thread.jsp...sageID=9396428
14/04/2007, 20h32
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:

MesResultats = maMethodeYahoo;

Moi je souhaite interompre comme suit
Code:

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.
15/04/2007, 11h47
Sanguko

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

Avec un Thread
ex:

Code:

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();

merci

Mais je ne comprends pas des masses votre thread.

Ma méthode, je la mets où?

Code:

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.

16/04/2007, 16h50
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...

++
16/04/2007, 16h54
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?
16/04/2007, 17h13
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é
16/04/2007, 20h28
jibbi

Faudrait nous donner un peu de code...:)

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

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:

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

Citation:

Envoyé par Terminator

Code:

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:

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:

resultats = YahooRequest.requete(maRequeteATester);

suffit

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

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
 
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:

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

devient alors

Code:

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.

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:

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;
 
	}
}

17/04/2007, 16h41
Terminator

Excellent,

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

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:

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:

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