Auf den Start eines Threads warten?

[Guest]

Hallo Leute,

ich habe einen TestCase in dem ich einen Thread aufmache. Der Thread soll auf ein bestimmtes Ereignis warten und dieses dann verarbeiten. Das Problem ist aber dass das Ereignis "manchmal" schon ausgelöst wird, obwohl der Thread von der JVM noch garnicht gestartet wurde (die "start"-Methode wurde aber natürlich vorher aufgerufen). Hat jemand eine Idee wie ich verhindern kann dass der Code/Test weiterläuft bevor der Thread gestartet wurde? Also im Prinzip ein "join" für den Start.

Danke schonmal.

Gruß Nova

 

[didjitalist]

dass der thread läuft weisst du in deiner entsprechenden run methode. also ist das einfachste, von dort aus einen entsprechenden hinweis zu senden, dass das ereignis ausgelöst werden darf.

 

[Guest]

Und dann das ganze mit einer While-Schleife blockieren bis das Flag umgesetzt wird? Naja, eine bessere Methode gibt es wohl nicht. ;-)

Danke.

 

[fjord]

wie wäre es mit einer CountDownLatch?

import java.util.concurrent.CountDownLatch;

public class Test
{
    public static void main(String[] args) {
    	final CountDownLatch latch = new CountDownLatch(1);    	
        Runnable r = new Runnable() {
        	public void run() {
        		System.out.println("waiting for latch");
        		try {
					latch.await();
				} catch (InterruptedException ie) {
					System.err.println(ie.getMessage());
				}
        		System.out.println("latch released");
        	}
        };
        new Thread(r).start();
        try {
        	Thread.sleep(10000);
        } catch (InterruptedException ie) {
        	System.err.println(ie.getMessage());
        }
        latch.countDown();
    }
}

 

[Ebenius]

Warten, bis ein Thread wirklich läuft sollte bspw. so gehen:

final boolean[] threadStarted = { false };
final Thread t = new Thread(new Runnable() {

  @Override
  public void run() {
    synchronized (threadStarted) {
      threadStarted[0] = true;
      threadStarted.notify();
    }
    // your stuff here
  }
});
t.start();
synchronized (threadStarted) {
  while (!threadStarted[0]) {
    try {
      threadStarted.wait();
    } catch (InterruptedException ex) {
      System.err.println("Bad luck!");
      Thread.currentThread().interrupt();
      return;
    }
  }
}
// Now the thread is definitely up and running

Ebenius