timeout realisieren

[ARadauer]

ich kann ich eigentlich am einfachsten einen Timeout realisieren?

package timeout;

import java.util.concurrent.TimeoutException;

public class TimeoutTest {
   
   public static void main(String[] args) {
      long t = System.currentTimeMillis();      
      try {
         //aktion durchführen
         doSomehting();
         long dauer = System.currentTimeMillis()-t;
         System.out.println("Dauer: "+dauer+" ms");
      } catch (TimeoutException e) {
         System.out.println("zu lange...");
      }      
   }
   
   public static void doSomehting() throws TimeoutException{     
      //mache etwas... wenn wir nach x sekunden nicht fertig sind, wirf die Exception
      throw new TimeoutException();
   }
}

wie macht man das am besten? zwei threads? der eine überwacht den anderen und weißt ihn bei bedarf an abzubrechen?

 

[tfa]

Auf jeden Fall mit Threads.
Im Concurrency-Framework gibt es schon solche Funktionalität: ExecutorService.invokeAny
Vielleicht ein wenig Overkill für nur einen Task...

Edit: invokeAny nicht invokeAll

 

[ARadauer]

mir kommt das auch so vor als wär das nicht der beste weg... ist doch etwas das man öfters brauchen kann. kann mir jemand ein beispiel geben, wie man sowas am besten macht?

 

[tfa]

Beispiel geben wofür? Für den Weg, den du nicht so gut findest (mit ExecutorService)?

 

[ARadauer]

package timeout;

import java.util.ArrayList;
import java.util.Collection;
import java.util.List;
import java.util.concurrent.Callable;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.Future;
import java.util.concurrent.TimeUnit;


public class TimeoutTest {

   public static void main(String[] args) {
      ExecutorService service = Executors.newSingleThreadScheduledExecutor();

      long t = System.currentTimeMillis();      
      try {

         Collection<Test> list =new ArrayList<Test>();
         list.add(new Test());         
         List<Future<String>> future = service.invokeAll(list, 1, TimeUnit.SECONDS);         

         if(future.get(0).isCancelled()){
            System.out.println("Timeout");
         }else{
            long dauer = System.currentTimeMillis()-t;
            System.out.println("Dauer: "+dauer+" ms");
         }
      } catch (InterruptedException e) {         
         e.printStackTrace();
      }      
   }

}

class Test implements Callable<String>{

   public String call() throws Exception {
      Thread.sleep(2000);
      return null;
   }

}

finde das mit der liste nicht sehr sauber, geht das nicht einfacher?

 

[tfa]

Mit dieser Klasse geht's wohl nicht anders. Die Liste ist halt überflüssig für deinen Fall. Unsauber würde ich das aber nicht nennen.
Vielleicht findet ja noch jemand eine andere Lösung.