alten Thread vor erneutem Aufruf schließen

[Nick0110]

Hi,
habe ein kleinen soundplayer geschrieben. Die dateien sind in einer Playlist vorhanden und können nacheinander abgespielt werden. Die Klasse die zum abspielen der Sounddatei zuständig ist, ist ein thread. Jetzt habe ich das Problem, das mein Programm zu erst kontrollieren soll ob eine datei bereits abgespielt wird, wenn ja soll er diese vorher schliessen. Ansonsten neuen Thread aufrufen.
Mein Code sieht folgendermaßen aus.
Hauptklasse:

if ((player != null) && (player.isAlive())) {
			      player.stopPlaying();
			      player = null;
			   }
else {...
                  player = new Player(in);
			  player.start();
       }

Mein Thread:

public void stopPlaying(){
		if(player!= null){
			player.interrupt();
			
		weiter = false;
		line.close();
		player = null;
		}
public void startPlaying(){
	
		while(weiter){
		int readBytes =0;
		byte[] data = new byte[20000];
	        line.start();		
		do{
			try {
			readBytes = in.read(data,0,data.length);
		}catch (Exception e){
			MainClass.logger.error(e.getMessage());
			System.exit(-3);
			}
		if (readBytes!=-1) line.write(data, 0, readBytes);
		} while (readBytes != -1);
		  
	}

Außerdem braucht das Programm viel zu viel Ressourcen und ich kann mir nicht erklären weshalb...
Danke!

 

[nebulo]

public void stopPlaying(){
      if(player!= null){
         player.interrupt();
         
      weiter = false;
      line.close();
      player = null;
      }
public void startPlaying(){
   
      while(weiter){
      int readBytes =0;
      byte[] data = new byte[20000];
           line.start();      
      do{
         try {
         readBytes = in.read(data,0,data.length);
      }catch (Exception e){
         MainClass.logger.error(e.getMessage());
         System.exit(-3);
         }
      if (readBytes!=-1) line.write(data, 0, readBytes);
      } while (readBytes != -1);
       
   }

Also das Ganze ist sicher kein Thread. Der Thread ist das was du mit line.start() oder vielleicht player.start() startest. Also um dir weiterhelfen zu können müsstest du schon angeben was line für ein Objekt ist und wie die run-Methode von line und player aussieht.

Gruß nebulo

 

[Nick0110]

Also hier mal der ganze Code von meinem Thread:

public class Player extends Thread{
	
	static boolean weiter;
	private AudioInputStream in = null;
	private SourceDataLine line = null;
	static Thread player = new Thread();
	static FloatControl gainControl;
	FloatControl gain;
	
	
	public Player(AudioInputStream aui){ 	
		weiter = true;
		MainClass.logger.info("\n Thread start, Name des Thread: "+ this.getName()+"\n");
		
		try{
		
			in = aui;
			
			System.out.println(in);
			System.out.println(aui);
			}catch (Exception d){
				MainClass.logger.error(d.getMessage());
			}			

	AudioFormat format = in.getFormat();
	
	DataLine.Info info = new DataLine.Info(SourceDataLine.class,format);
	try {
		line = (SourceDataLine)AudioSystem.getLine(info);
		MainFrame.source = (SourceDataLine)AudioSystem.getLine(info);
		line.open(format);
		
		System.out.println("Lautstärke : "+ gainControl);
		}catch (Exception e) {
			MainClass.logger.error(e.getMessage());
		System.exit(-2);
		}
		
		
	}
		
	public void stopPlaying(){
		if(player!= null){
			player.interrupt();
			
		weiter = false;
		line.close();
		player = null;
		}
		
	}
	
	public void pause(){
		line.stop();
		
	}
	
	public void resumeSound(){
		line.start();
	}
	
	public void run(){
		startPlaying();
	}
	
	public void startPlaying(){
	
		while(weiter){
		int readBytes =0;
		byte[] data = new byte[20000];
		
		
		int vol = 0;
				
		
		line.start();		
		do{
			try {
			readBytes = in.read(data,0,data.length);
		}catch (Exception e){
			MainClass.logger.error(e.getMessage());
			System.exit(-3);
			}
		if (readBytes!=-1) line.write(data, 0, readBytes);
		} while (readBytes != -1);
		  
	}
	
	}	
}

Danke für die Hilfe!

 

[nebulo]

So wie ich das verstehe instanzierst du momentan für jeden Song ein eigenes Player-Objekt!? Warum setzt du nicht einfach ein boolean playing auf true wenn das Objekt instanziert wird und ganz am Ende von startPlaying() auf false. Ebenso bei stopPlaying. Dann brauchst du nur noch ein Methode isPlaying die dir playing zurückgibt.

Dann kannst du einfach so oder so ähnlich prüfen ob ein Song abgespielt wird:

if(!playerobeject.isPlaying()){
   playerobject = new Player(in);
   playerobject.start();
}

Oder hab ich jetzt mißverstanden was dass Problem ist?

Du solltest übrigens die startPlaying() private deklarieren und vielleicht synchronized. Bin selbst nicht der Experte was Threads betrifft.

 

[Saxony]

Du solltest übrigens die startPlaying() private deklarieren und vielleicht synchronized. Bin selbst nicht der Experte was Threads betrifft.

Dem private stimme ich zu.
Aber wenn (wirklich) nur ein Thread auf eine Methode zugreift, sollte man das synchronized weglassen.
Dazu muss aber sicher gestellt sein, dass keine Laufzeitabhängigkeiten (race conditions) der (unsynchronisierten) Methode zu anderen Threads bestehen.

[edit]
So das mit synchronized ist egal. Laut dem hier gibt es keine Laufzeiteinbußen.
[/edit]

bye Saxony

 

[Nick0110]

Eine boolean Variable hab ich ja drin, ist in meinem Fall boolean weiter. Irgendwie hat sich das Problem auch wieder erledigt. Mit

if(player != null){
	                player.stopPlaying();
	                player.interrupt();
	            player = null;
}

wird der Thread wieder geschlossen. Aber wie kann ich noch das Ende des Audiosignals abfragen, damit der Thread automatisch geschlossen wird? Bisher muss ich immer auf den Button stop drücken, der obigen Code ausführt.

 

[nebulo]

Hm also ich bin mir nicht sicher was du willst.

while(weiter){
      int readBytes =0;
      byte[] data = new byte[20000];
      
      
      int vol = 0;
            
      
      line.start();      
      do{
         try {
         readBytes = in.read(data,0,data.length);
      }catch (Exception e){
         MainClass.logger.error(e.getMessage());
         System.exit(-3);
         }
      if (readBytes!=-1) line.write(data, 0, readBytes);
      } while (readBytes != -1);

Das ist ja der eigentliche Code, der innerhalb des Threads ausgeführt wird. Wenn nun also keine weiteren Bytes mehr gelesen werden (also readBytes == -1) ist die Datei zu Ende und damit die Methode abgerabeitet.

 

[Nick0110]

Ja das sehe ich auch so. Aber mein Taskmanager sagt anderes. Beim abspielen werden ca. 50% Ressourcen verbraucht, die nach dem Ende der Datei eigentlich wieder freigegeben werden müssten. Das ist aber nicht der Fall, erst wenn ich den stop Button betätige. Der Code zum stop button sieht so aus:

if (label.equals("stop")){
			
			 if(player != null){
	                player.stopPlaying();
	                player.interrupt();
	            player = null;
	            recStatus.setForeground(Color.BLACK);
	            recStatus.setText("stop");
}

Wieso wird der Thread nicht automatisch gekillt, wenn die Datei fertig gelesen wurde?

 

[nebulo]

Ich meine das ist sicher keine saubere Lösung aber dann führe am Ende der startPlaying() doch einfach diesen Code aus. ...

 

[Nick0110]

Ha,
ich glaub ich hab das Problem gefunden,
in der if-Anweisung hat das else gefehlt, somit wurde weiter nie auf false gesetzt :idea: und er kam nie aus der Do-while schleife raus.

if (readBytes!=-1) line.write(data, 0, readBytes);
		else weiter = false;

Wahnsinn....
Danke