Problem mit Threads

[JavaNooby]

Hallo,

habe ein Problem mit Threads und komme seit ca 1 Std nicht weiter:

			// start the progress bar
			Thread t1 = new Thread(new progressbarThread());
			t1.start();
			
			// zip the directory
			addTextToEncryptLogTextArea("Creating archive for encrypting...");
			Thread t2 = new Thread(new zipThread());
			t2.start();
			
			// crypt the directory
			addTextToEncryptLogTextArea("Encrypting archive...");
			Thread t3 = new Thread(new cryptThread());
			t3.start();

Wie mach ich es dort, dass thread t3 auf thread t2 wartet bis dieser fertig ist? Komme leider nicht weiter 🙁

P.S. Geht mir hauptsächlich darum dass die ausgaben addText blabla erst ankommen wenn der thread fertig ist. Ist in nem GUI log fenster und das sollte schon korrekt sein 🙂

 

[SlaterB]

schaue dir die Operation Thread.join() an,

alternativ lasse das ZipThread-Objekt (Klassen groß schreiben!) einfach eine Operation ready() oder so anbieten, die irgendwann korrekt true gibt,
CryptThread ruft ab und zu diese Operation

alternativ verwende ein Synchronisationsobjekt mit wait/ notify,
da lies dann aber besser erstmal ein Kapitel zu Threads in einem Lehrbuch..

http://www.galileocomputing.de/openbook/javainsel6/

 

[Ark]

Mist, zu spät. >_<

Ark 😉

 

[Viperb0y]

Hallo,

das mit dem Thread.join() habe ich auch schon versucht. Verstehe es allerdings nicht, das openbook sagt mir dazu leider nicht wirklich etwas genaues 🙁

Das mit dem boolean ready war gute idee, allerdings hapert es an der umsetzung.. "cannot make a static reference".. okay, mach ich ein static draus.. "please remove static from".. okay, dann ebend nicht 😀

 

[SlaterB]

was gibt es denn an

package com.javatutor.insel.thread; 
 
class JoinTheThread 
{ 
  static class JoinerThread extends Thread 
  { 
    public int result; 
 
    @Override public void run() 
    { 
      result = 1; 
    } 
  } 
 
  public static void main( String[] args ) throws InterruptedException 
  { 
    JoinerThread t = new JoinerThread(); 
    t.start(); 
//    t.join(); 
    System.out.println( t.result ); 
  } 
}

http://www.galileocomputing.de/open...09_004.htm#mjdd6a64976ce2671dcd8f72a09df8e78e

nicht zu verstehen?

der main-Thread wartet mit join auf einen anderen,
genauso könntest du es machen (es ist natürlich wichtig, wer wen wann aufruft)

-------

bei der ready-Idee ist es wichtig, 'static' nirgendwo zu verwenden 😉


stelle genauere Fragen/ mehr Code, dann kann man mehr verraten

 

[Viperb0y]

Hallo,

okay, .join geht nun aber kann ich nicht verwenden da ich dann wieder meine gui blockiert bekomme.. genau deswegen habe ich ja threads gewählt 😉.

Beispiel:

			if (CryptThread.ready)
			{
				addTextToEncryptLogTextArea("Done!");
			}

Bekomm ich: Cannot make a static reference to the non-static field CryptThread.ready

	public class CryptThread extends Thread
	{
		public boolean ready;
		
		public void run() 
		{
			try
			{
				Crypt.encryptFile(outputFileTextField.getText(), outputFileTextField.getText() + ".enc", "12345678");
				ready = true;
			}
			catch (Exception e)
			{
				addTextToEncryptLogTextArea(e.toString());
			}
		}
	}

Hier noch Crypt:

public class Crypt
{
	public static void encryptFile(String input, String output, String pwd) throws Exception
	{
		CipherOutputStream out;
		InputStream in;
		Cipher cipher;
		SecretKey key;
		byte[] byteBuffer;   
		
		// set encrypt algorithm
		cipher = Cipher.getInstance("DES");
		// turn in the password
		key = new SecretKeySpec(pwd.getBytes(), "DES");
		// initiate the encrypting
		cipher.init(Cipher.ENCRYPT_MODE, key);
		
		in = new FileInputStream(input);
		out = new CipherOutputStream(new FileOutputStream(output), cipher);
		
		byteBuffer = new byte[1024];
		
		for (int n; (n = in.read(byteBuffer)) != -1; out.write(byteBuffer, 0, n));
		
		// close file handles
		in.close();
		out.close();
	   }
}

Noch etwas benötigt, sorry, aber ich bin in dem Bereich recht neu 🙁

 

[SlaterB]

> okay, .join geht nun aber kann ich nicht verwenden da ich dann wieder meine gui blockiert bekomme.. genau deswegen habe ich ja threads gewählt

wie gesagt: bedenke, wer auf wen warten soll,

nämlich ein Thread auf den anderen, dann kann die GUI gar nicht lahmgelegt werden,

wenn du im Moment den GUI-Thread anhälst dann ist die einfache Lösung: tue dies nicht,
nur die Threads sollen untereinander warten,
z.B. in der run-Operation des einen .join() des anderen aufrufen,

das funktioniert natürlich nur, wenn man eine Referenz auf dieses andere Thread-Objekt hat,


genauso bei ready,
> if (CryptThread.ready)
ist Käse,

if (cryptThreadObject.ready)
muss das heißen,
cryptThreadObject ist das t2-Objekt vom Anfang?,

damit t3 t2 kennt, muss t3 natürlich diese Referenz irgendwie bekommen, z.B. in Konstruktor als Parameter übergeben und dann intern als Exemplarvariable speichern