Condition Problem

[Sanix]

Hi,
Ich habe ein bisschen mit Locks rumexperimentiert, verstehe jedoch nicht, wieso ich hier eine IllegalMonitorStateException kriege:

public class Thread1 implements Runnable
{

	public static void main(String[] args) 
	{
		new Thread(new Thread1()).start();
	}
	
	public void run() 
	{
		Lock lock = new ReentrantLock();
		lock.lock();
		
		Condition cond = lock.newCondition();
		
		new Thread(new Thread2(cond)).start();
		
		try
		{
			System.out.println("Warte auf Signal");
			cond.await();
			System.out.println("Signal erhalten");
		}
		catch(Exception ex)
		{
			System.err.println(ex);
		}
	}

}



public class Thread2 implements Runnable
{
	Condition cond;
	
	public Thread2(Condition cond) 
	{
		this.cond = cond;
	}
	

	public void run() 
	{
		System.out.println("Hi, ich warte 5s");
		try
		{
			Thread.sleep(5000);
			System.out.println("Sende Signal");
			cond.signal();
		}
		catch(Exception ex)
		{
			System.err.println(ex);
		}
	}

}

 

[Sanix]

Weiss Niemand eine Antwort?

 

[HoaX]

weil du ein synchronized auf das objekt brauchst, bei dem du Object.wait() aufrufst.

steht auch breit in der api-doc: http://java.sun.com/j2se/1.5.0/docs/api/java/lang/Object.html#wait()

 

[Sanix]

Das hilft mir leider auch nicht. Ich benutze das await des Condition Objekts.

 

[SlaterB]

auch dieses braucht ein synchronized, hier in Form eines lock.lock(); Aufrufs,
siehe z.B. das ganz initiale simpelst mögliche Beispiel in der API.. (oben)

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

 

[Sanix]

Ich habe die 2. Klasse wie folgt abgeändert:

public class Thread2 implements Runnable
{
	Condition cond;
	Lock lock;
	
	public Thread2(Condition cond, Lock lock) 
	{
		this.cond = cond;
		this.lock = lock;
	}
	

	public void run() 
	{
		lock.lock();
		System.out.println("Hi, ich warte 5s");
		try
		{
			Thread.sleep(5000);
			System.out.println("Sende Signal");
			cond.signal();
		}
		catch(Exception ex)
		{
			System.err.println(ex);
		}
	}

}

Nun kriege ich keine Exception mehr, das Signal wird gesendet, jedoch passiert nichts. Ich verstehe 2 Dinge nicht ganz:
- Ein lock lässt doch das Programm warten, wieso muss es in beiden Threads ausgeführt werden? Woher wissen die Threads, welcher zum Synchronisieren ist und welcher warten muss?
- Wieso funktioniert es immer noch nicht?

 

[SlaterB]

> Ein lock lässt doch das Programm warten, wieso muss es in beiden Threads ausgeführt werden?

falsch, ein lock macht nur das was sonst synchronized macht

> Woher wissen die Threads, welcher zum Synchronisieren ist und welcher warten muss?

beide synchronisieren, einer ruft await() auf

> Wieso funktioniert es immer noch nicht?

weil du das Beispiel aus dem Link nicht vollständig abgetippt hast?!

kleiner Rätsel-Tipp: bei normalen synchronized darf der aufgeweckte Thread erst dann weitermachen,
wenn der aufweckende Thread den synchronized-Block verlassen hat,
es darf immer nur ein Thread in einem synchronized-Block sein