läuft der thread eigentlich weiter?

[noobster]

hi blöde frage weil ich dazu nichts gefunden habe,

ich bastle an einem socketserver,da es hin und wieder zu Problemen kam wenn der client geschlossen wurde ohne den stream zu closen.

Ich hab mich inzwischen etwas in die exceptions reingearbeitet und es nach mehreren versuchen soweit optimiert das der multithreaded socketserver schön weiterläuft anstatt sich kurzweilig aufzuhängen und anstelle dessen mit catch und einer Exception sowie

in.close();
out.close();

den BufferReader und den PrintWriter schliesst,

was mir jetzt nicht klar ist, ob der thread jetzt dadurch auch beendet ist oder weiterläuft?
sorry für meine unwissenheit

 

[byte]

Der Task ist beendet sobald die run() des Runnables beendet ist. Am besten verwendet man Executor zum Verwalten der Threads - dann kümmert sich Java automatisch um die Threads, Java SE5 vorausgesetzt.

 

[noobster]

hey Danke, ich habs zwar jetzt schon mit

Thread.currentThread().stop();
threadDeath;

gemacht weil er auf ein interrupt nicht reagiert hat aber ich werd mir das mit dem executer auf jedenfall durchlesen und ggf umändern, will mir nicht wie früher bei anderen sachen erstmal nur die einfachen dinge aneigenen um nachher wieder alles "um"lernen zu müssen, nur weil man schneller erfolge hatte

 

[byte]

Die API hat dahingehend sogar ein Beispiel für Serversockets parat, sehe ich grade:

 class NetworkService {
    private final ServerSocket serverSocket;
    private final ExecutorService pool;

    public NetworkService(int port, int poolSize) throws IOException {
      serverSocket = new ServerSocket(port);
      pool = Executors.newFixedThreadPool(poolSize);
    }
 
    public void serve() {
      try {
        for (;;) {
          pool.execute(new Handler(serverSocket.accept()));
        }
      } catch (IOException ex) {
        pool.shutdown();
      }
    }
  }

  class Handler implements Runnable {
    private final Socket socket;
    Handler(Socket socket) { this.socket = socket; }
    public void run() {
      // read and service request
    }
 }

http://java.sun.com/j2se/1.5.0/docs/api/java/util/concurrent/ExecutorService.html

 

[noobster]

hey nochmal danke, das konstrukt kenne ich aus ActionScript als eventhandler für listener ,

das

newFixedThreadPool

bedeuted aber das ich nur eine festgelegte anzahl an threads zur verfügung stehen habe oder?
Hat das in meiner anwendung einen sinn ausser evtl der beschränkung der "concurrent users"?

könnte ich anstelle dessen nicht

newCachedThreadPool

nehmen, oder spricht etwas dagegen?

Gruss Sascha

ps:
Du weisst immer soviel , wenn ich daten an die socket sende...

else {
           out.println(line + "_Ausgabe an Client\n\0");
           System.out.println("___>1");
         textArea.append(line);
         System.out.println("___>2");
        }

die ausgabe an den client erfolgt sofort
das system out ___1 kommt unterschiedlich schnell mal sofort mal nach 5 sekunden mal nach noch längerer zeit
das der text dann schlussendlich in der textarea ankommt kann 20 sekunden dauern oder es geschieht erst nachdem ich den client geschlossen habe , ich habe in allen try und catch geschichten eine ausgabe für die console aber es wird anscheinend nichts anderes durchlaufen.

das ganze ist nur bei der zweiten nachricht die ich sende so

die erste ist ein String "saveFile" der wird automatisch vom client gesendet hatte damals eine testfunktion, nunja nun habe ich eine textarea flashclient eingebaut und sende den string zur socket, nur halt bei der ersten eingabe im textfeld (textarea) hab ich besagtes problem, komischerweise kommen an der socket anführende "%0A%0D" (url encoded) an welche ich entferne, kanns daran liegen?

 

[byte]

Wenn Du die maximale Anzahl Threads nicht beschränken willst, dann kannst Du genauso gut einen CachedThreadPool verwenden, das ist vollkommen korrekt. Du kannst aber unter Umständen Performanceprobleme kriegen, wenn zuviele Threads geöffnet werden. Aber generell kann man erstmal so testen und bei Bedarf dann später eine Obergrenze einbauen.

Mit Sockets kenne ich mich sonst nicht großartig aus, sry.

 

[noobster]

Mit Sockets kenne ich mich sonst nicht großartig aus, sry.

auch wenn dem so sein sollte einen riesigen dank schonmal für deine Antworten, die haben mirwirklich sehr weiter geholfen auch diese URLEncoder geschichte aus meinem source hab ich von dir aus einem anderen Beitrag hab mich fast totgesucht was es vergleichbares in java gibt, damit filtere ich unerwünschte zeichen die beim senden endstehen (weiss der Geier wieso), wie du siehst hast du mir schon sehr geholfen

Ich werd nun mal versuchen alles nach zu vollziehen und mal schauen was ich so übers Java debugging finde.
Ich will wissen was das Ding macht während es nix macht

Gruss Sascha

 

[byte]

Welche Entwicklungsumgebung verwendest Du denn? Eclipse hat einen sehr schönen Debugger.

www.eclipse.org

 

[noobster]

Welche Entwicklungsumgebung verwendest Du denn? Eclipse hat einen sehr schönen Debugger.

www.eclipse.org

jap den benutze ich und freunde mich gerade damit an :

http://www.java-forum.org/de/viewtopic.php?t=34691

hoffe war ok das ich nen neuen beitrag dafür aufgmacht habe.

Gruss Sascha

 

[Leroy42]

Am besten verwendet man Executor zum Verwalten der Threads

Wer ist das denn? :shock:

Wo find' ich den? ???:L :### ???:L

 

[noobster]

oben war doch ein link von byto...

http://java.sun.com/j2se/1.5.0/docs/api/java/util/concurrent/ExecutorService.html

Gruss Sascha

 

[byte]

Am besten verwendet man Executor zum Verwalten der Threads

Wer ist das denn? :shock:

Wo find' ich den? ???:L :### ???:L

Wenn Dich das schon schockt, dann such mal nach java.util.concurrent.Future !

 

[noobster]

hey cool, danke...


das Future ist genau das was ich brauche.

wann wird der bufferedReader eigentlich geleert, wenn er voll ist, was wenn grössere datenmengen ankommen??
ich hab zumindest hier:

http://java.sun.com/j2se/1.5.0/docs/api/java/io/BufferedReader.html

leider nichts dazu gefunden

btw. ich frage weil ich future nutzen wollte um in einem thread die zeichen mit read()aus einem BufferedReader auszulesen und in einem beiläufigen task den spass abzuarbeiten, nun die frage, globale variable->String oder array in den geschrieben wird und aus dem gelesen wird, sozusagen als "Stack".

oder kann ich den BufferedReader auch zweimal auslesen, ich las da was von einer methode "mark()" hab aber nix gefunden wozu man diese sinniger weise nutzen könnte , weil ich fand zwar ein sprungkomando "skip()" aber keinen um zu lesen WO der string markiert ist?

Gruss Sascha

 

[Johnna Curtis]

vp50vo4mr437g00f