Как ограничить время выполнения потока и завершить его, если он работает слишком долго?

Question

Общий вопрос для моего вопроса состоял в том, как мы обнаруживаем, что какой-либо вызов функции длился слишком долго, так что мы хотим его прекратить?

На верхней части моей головы, я думаю использовать нить для выполнения этой функции, и убить нить, если он работает слишком долго, как определено ниже:

class MyThread extends Thread 
{ 
    public void run() 
    { 
    someFunction(); 
    } 
} 

И сказать SomeFunction может быть:

public void someFunction() 
{ 
    // Unknown code that could take arbitrarily long time. 
} 

В приведенном выше коде someFunction() может занять некоторое время, чтобы закончить или использовать его навсегда, поэтому скажите, что я хочу остановить его, когда он слишком долго.

Однако в реализации потока Java, по-видимому, я не могу использовать общую переменную или любую временную метку в потоке, так что поток будет иметь смысл времени, потому что someFunction() смешно атомизирует и такой код проверки на отметку времени может идти только после someFunction, что становится бесполезным, поскольку в момент выполнения кодирования некоторая функция уже выполнена.

ПРИМЕЧАНИЕ: Я также хочу сделать это с someFunction(), являющимся агностиком. То есть someFunction() не должен беспокоиться о том, сколько времени он запускает. Он просто не должен об этом знать.

Может ли кто-нибудь дать представление о том, как я могу выполнить эту функцию?

Answer 1

Я бы использовал ExecutorService для запуска потока. Затем я вернусь Future и воспользуюсь get() с таймаутом, чтобы отменить его.

ExecutorService es = Executors.newFixedThreadPool(1); // You only asked for 1 thread 
Future<?> future = es.submit(new Mythread()); 
try { 
    future.get(timeout, TimeUnit.SECONDS); // This waits timeout seconds; returns null 
} catch(TimeoutException e) { 
    future.cancel(true); 
}