Thread interrupt

[Ghorki]

Hi Leute,

Ich habe Probleme beim sauberen schließen bzw starten meines Threads.
Wenn ich den Server Thread von meiner anderen Klasse aus interrupte und ihn dann wieder neu starten möchte, geht er mir leider in der start() Methode in den catch Zweig :/.

Könnt ihr mir behilflich sein?
Danke schonmal für eure Hilfe.

MfG
Ghorki

public class Server extends Thread
{
	private Server server;

	public void run() 
	{				
			while(true) 
			{
					System.out.println("client an handler übergeben");
					Thread.sleep(1000);	
			}
	}

	public synchronized void start(JTextArea serverlog_textarea) 
	{
			serverlog_textarea.append("Server starten..");
			try 
			{
				super.start();
				setServerStatus(true);
				serverlog_textarea.append("abgeschlossen\n");
			} 
			catch (Exception e) 
			{
				setServerStatus(false);
				serverlog_textarea.append("fehler\n");
			}
		}
	}
	
	public void interrupt(JTextArea serverlog_textarea) 
	{
		serverlog_textarea.append("Server beenden..");
		try 
		{
			super.interrupt();
			setServerStatus(false);
			serverlog_textarea.append("abgeschlossen\n");
		} 
		catch (Exception e) 
		{
			serverlog_textarea.append("fehler\n");
		}
	}
}

Aufgerufen wird dieser Thread in einer anderen Klasse.

public class Frame 
{
	Server server = new Server();
	
	// actionlistener 1
	server.start();

	// actionlistener 2
	server.interrupt();
}

 

[precoc]

Des selbe Problem hatte ich gerade auch hier.. es liegt da dran, das man nicht zwei mal den selben Thread aufrufen kann ..

Kann es sein, dass Du den selben Thread versuchst nochmal zu starten? Das geht nicht, ein Thread kann nur einmal ausgeführt werden, Du müsstest einen neuen Thread erzeugen. Besser als "extends Thread" wäre "implements Runnable". Das Runnable Objekt könntest Du im neuen Thread einfach wiederverwenden.
Wie stoppst Du denn das ganze? Deine Schleife in der listenPortOnce() ist ja eine Endlosschleife.
Je nachdem wie sauber man das ganze machen will, könnte man aus einem anderen Thread ein close() auf das ServerSocket aufrufen, um das blockierende accept() abzubrechen - dabei wird allerdings eine IOException geworfen. Beim "Neustarten" erzeugt man einfach ein neues ServerSocket und geht dann wie gehabt in die accept() Schleife.

So aehnlich wirds auch bei dir sein ..

 

[Ghorki]

Wenn ich implement benutze, wie lassen sich dann die Methoden überschreiben?

 

[precoc]

Ich hoffe ich hab das jetzt richtig verstanden, aber mach es doch so

new Thread(
    new Runnable() {
        @Override
        public void run() {
        /*
          inhalt des neuen Threads
        */
}
}
)

 

[Ghorki]

Hi,

ich meine, wenn ich meine Klasse von Thread erben lasse, kann ich die deren Methoden überschreiben (was ich für meine Anwendung brauche), aber wenn ich nur Runnable implementiere, geht dass dann auch und wenn ja, wie? =)

 

[Warrior7777]

Ich weiß jetzt nicht, ob ich Dich richtig verstanden habe. Du übergibst also zweimal dasselbe Objekt, das entweder von Thread erbt oder Runnable implementiert, an Thread.start(). Vielleicht wird dadurch der erste Thread beendet o. Ä. Versuchs mal, indem Du zwei verschiedene Objekte (derselben Klasse) instanzierst und übergibst.
Viel Glück, Vergnügen und Erfolg!

 

[Michael...]

ich meine, wenn ich meine Klasse von Thread erben lasse, kann ich die deren Methoden überschreiben (was ich für meine Anwendung brauche)

Die Aussage in Klammern zweifle ich mal an ;-) Grundsätzlich ist die Implementierung eines Interfaces einer Erweiterung einer konkreten Klasse vorzuziehen.
==> eigene Klasse implements Runnable, run Methode implementieren (reicht in 99,9% aller Fälle). Runnable Objekt einem Thread übergeben.

Von Prinzip her so:

Runnable runnable = new Runnable() {
    public void run() {
        System.out.println("running");
    }
};

Thread thread = new Thread(runnable);
thread.start();

 

[bERt0r]

Die Methode start(JTextArea serverlog_textarea) überschreibt die Methode start() nicht. Du rufst nach wir vor die normale start() Methode auf. Wenn zwei Methoden gleich heißen, entscheiden die Parameter welche Methode ausgeführt wird. Du kannst ja mal ein @Override Tag vor die Methode schreiben, dann bekommst du auch deinen Compilefehler.

 

[Attila]

Srv srv = new Srv();

// actionlistener 1
srv.srvStart();
 
// actionlistener 2
srv.srvShutdown();
//...

static class SrvTask implements Runnable{
    public void run() {
       while ( !Thread.currentThread().isInterrupted() ) {
          try {
              System.out.println("SrvTask run ...");
              Thread.sleep( 1000 );
          } catch ( InterruptedException e ){
              Thread.currentThread().interrupt();
          }
       }
    }
}
static class Srv {
    private Thread thread;
    public synchronized void srvStart(){
        if ( ( thread == null ) || ( !thread.isAlive() ) ){
            thread = new Thread(new SrvTask());
            thread.start();
            System.out.println("SrvTask start ...");
        }
    }
    public synchronized void srvShutdown(){
        if ( ( thread != null ) && ( thread.isAlive() ) ){
            thread.interrupt();
            try {
                thread.join();
                System.out.println("SrvTask shutdown ...");
            } catch (InterruptedException ex) { }
        }
    }
}

 

[Ghorki]

Danke an alle.

@Attila
Super Beispiel, danke dir. Habs nun in dieer Weise eingebaut