Threads unterbrechen

[Rahmspinat]

Hi ihrs,

ich habe ein Programm geschrieben das Webseiten ausliest und auswertet.

Das ganze funktioniert über mehrere Threads.

Manchmal braucht ein Thread Ewigkeiten, eh er eine Seite ausgelesen hat und wenn ich das wiederhole, braucht die gleiche Seite mit der gleichen Funktion nur ein paar Sekunden.

Ich wollte das ganze jetzt so gestalten, dass wenn das Programm z.B. nach 15 Sekunden eine Seite nicht eingelesen hat die Funktion neustartet. Allerdings gestaltet die ganze Sache sich schwieriger als gedacht.

Ich hab erst gedacht, dass ich den Thread mit interrupt() dazu bringen kann, seine aktuelle Aufgabe zu unterbrechen und mit der nächsten zu beginnen.

Kennt ihr eine Möglichkeit den Thread so zu unterbrechen, dass er seine aktuelle Aufgabe vergisst und mit der nächsten beginnt?

Gruß Martin

 

[SlaterB]

wenn ein Thread selber arbeitet, kann er ja alle paar Arbeitsschritte nach einem extern gesetzten boolean schauen und darauf zur nächsten Aufgabe wechseln oder ähnliches,

deine Beschreibung klingt aber eher danach, dass der Thread nur auf eine Webseite wartet, per read auf einem Stream von einem Socket oder ähnliches,
da kann man sicher einen Timeout setzen, mit dem Nachteil, dass dann evtl. Verbindungen nie lange genug durchgehalten werden, bis tatsächlich noch was kommt,

und was man auch bedenken könnte: solange der Thread auf die Webseite wartet, belastet er das System ja quasi nicht,
bedenke also die Möglichkeit, den Thread solange warten zu lassen und stattdessen schon einen neuen zu starten, der dessen Aufgabe übernimmt,
der erste Thread kann ja wiederum ein boolean-Falg bekommen mit der Aussage 'falls du je mit deiner aktuellen Seite fertig wirst, dann bist du gefeuert, mache nix weiter'

einen neuen Thread zu starten ist natürlich immer noch ein gewisser Aufwand, sowohl bei Performance als auch Organisation

 

[miwoe]

Wenn du es wirklich so machen willst, ist es doch ganz einfach.

Was immer auch eine Referenz zu dem Thread hat

- Zeit messen
- Warten
- Prüfen ob Thread noch aktiv
- Thread "interrupt"-en

Womit machst du denn die Http-Anfragen? Vielleicht hat die Funktion selbst schon eine Timeout-Möglichkeit.

 

[Rahmspinat]

Das hört sich doch alles schonmal sehr gut an

Den Thread einfach dazu bewegen nur noch diese Abfrage weiterlaufen zu lassen und dessen weitere Aufgabe abzugeben, find ich gut.

Schön wäre auch ein Timeout.
Ich poste mal den Code mit dem ich die Seite auslese. Vielleicht habt ihr ne Idee fürn Timeout

public String einlesen() {
        
        String code = "";
        try {                                          
            URL myUrl = new URL(verlinkendeSeite);            
            URLConnection myUrlCon = myUrl.openConnection();

            InputStream in = myUrlCon.getInputStream();

            in = new BufferedInputStream(in);  
            Reader r = new InputStreamReader(in);

            int c;     
            
            while((c = r.read()) != -1) {
                
                if((char)c != '\n') {
                   code = code + (char)c;  
                }
            }
         }catch(Exception ex) {
             System.out.println(ex.getMessage());
             return "Fehler";
         }
        
        return code;
    }

 

[SlaterB]

setConnectTimeout()?
kann man doch nachschauen,

auch
Google

 

[FArt]

ExecutorService (Java 2 Platform SE 5.0)

 

[miwoe]

Ich benutze HttpClient von Apache. Da gibt es auch ein TimeoutController.

HttpComponents - HttpComponents Overview

 

[Rahmspinat]

also ich habe festgestellt, dass das Programm öfter beim ".getInputStream()" hängt

Da kommen Zeiten von 1640,766 Sekunden zu stande....

            double start = System.currentTimeMillis();
            InputStream in = myUrlCon.getInputStream();
            double inputTime = System.currentTimeMillis() - start;

Ich hab das mal mit .setConnectTimeout() versucht

            URL myUrl = new URL(seite);     
            URLConnection myUrlCon = myUrl.openConnection();

            myUrlCon.setConnectTimeout(2000);
            
            double start = System.currentTimeMillis();
            InputStream in = myUrlCon.getInputStream();
            double inputTime = System.currentTimeMillis() - start;

es kommen trotzdem Zeiten von 265,781 Sekunden zu stande. dass so eine große Zahl wie die erste nicht zu stande gekommen ist, ist wohl er Zufall als aufgrund des setconnectTimeout. Jemand eine Idee ob ich das ganze vielleicht falsch verwende?

 

[SlaterB]

public void setConnectTimeout(int timeout)
[..]
Some non-standard implmentation of this method may ignore the specified timeout. To see the connect timeout set, please call getConnectTimeout().

;(

 

[Rahmspinat]

Das ist wirklich zum heulen ;(

Hab ich wohl leider überlesen.

Ich hab für heute echt die Nase voll. Beschäftige mich seit heute morgen damit...

Ich geh jetzt erstmal Heim und entspann mich und probier morgen die anderen Vorschläge durch! Muss ja wohl irgendwie gehen.

gruß Martin