Le temps de la méthode en java

Dans une classe java, j'ai une méthode qui parfois prend beaucoup de temps pour l'exécution. Peut-être qu'il se bloque dans la méthode des flux. Ce que je veux, c'est si la méthode n'a pas terminé dans les temps spécifique, le programme devrait sortir de cette méthode et de continuer avec le reste de l'écoulement.

S'il vous plaît laissez-moi savoir est-il de toute façon de gérer cette situation.

OriginalL'auteur Ran | 2012-01-24

java

Vous devez utiliser les threads pour atteindre cet objectif. Les Threads ne sont pas nuisibles 🙂 Exemple ci-dessous exécuter un morceau de code pendant 10 secondes, puis se termine.

public class Test {
    public static void main(String args[])
        throws InterruptedException {

        Thread thread = new Thread(new Runnable() {
            @Override
            public void run() {
                System.out.println("0");
                method();
            }
        });
        thread.start();
        long endTimeMillis = System.currentTimeMillis() + 10000;
        while (thread.isAlive()) {
            if (System.currentTimeMillis() > endTimeMillis) {
                System.out.println("1");
                break;
            }
            try {
                System.out.println("2");
                Thread.sleep(500);
            }
            catch (InterruptedException t) {}
        }


    }

    static void method() {
        long endTimeMillis = System.currentTimeMillis() + 10000;
        while (true) {
            //method logic
            System.out.println("3");
            if (System.currentTimeMillis() > endTimeMillis) {
                //do some clean-up
                System.out.println("4");
                return;
            }
        }
    }
}

Super! Travaillé amené à la perfection pour moi.

OriginalL'auteur Muhammad Imran Tariq

1

Exécuter la méthode dans un thread différent, vous pouvez mettre fin à un fil à tout moment.

Est-il possible avec l'aide de Threads.Je ne veux pas utiliser des Threads.
ne voulez pas utiliser les Threads Pourquoi? Si vous n'êtes pas familier, avoir un regard sur le java tutoriel
Salut Xavier, le problème avec les threads, c'est que nous ne sommes pas sûr à propos de l'exécution de fil débit si nous avons plusieurs threads en cours d'exécution pour la même portion de code qui semble être un peu complexe à gérer ou de débogage.
Jetez un oeil à java.util.concurrent.* surtout FutureTask, Callable et Executors. Voir ce fil de réponse pour un exemple: StackOverflow Question 240320.
les threads en cours d'exécution pour la même portion de code ?? BTW, regardez le tutoriel, j'ai fait un lien dans le commentaire précédent.

OriginalL'auteur COD3BOY

Basé sur la ci-dessus snipplet, j'ai essayé de créer une glorifié printemps bean.

Tels exécuteur exécute le passé limitedRuntimeTask limitée runtimeInMs.
Si la tâche est terminée à l'intérieur de ses limites, l'appelant se poursuit normalement dans l'exécution.

Si le limitedRuntimeTask ne parvient pas à terminer dans la runtimeInMs,
l'appelant recevra l'exécution du thread en arrière. Si un timeBreachedTask a été défini,
il sera exécuté avant de retourner à l'appelant.

public class LimitedRuntimeExecutorImpl {


public void runTaskInLessThanGivenMs(int runtimeInMs, final Callable limitedRuntimeTask, final Callable timeBreachedTask) {
    Thread thread = new Thread(new Runnable() {
        @Override
        public void run() {
            try {
                LOGGER.info("Started limitedRuntimeTask");
                limitedRuntimeTask.call();
                LOGGER.info("Finished limitedRuntimeTask in time");
            } catch (Exception e) {
                LOGGER.error("LimitedRuntimeTask exception", e);
            }
        }
    });
    thread.start();

    long endTimeMillis = System.currentTimeMillis() + runtimeInMs;

    while (thread.isAlive()) {
        if (System.currentTimeMillis() > endTimeMillis) {
            LOGGER.warn("LmitedRuntimeTask did not finish in time (" + runtimeInMs + ")ms. It will run in vain.");
            if(timeBreachedTask != null ){
                try {
                    LOGGER.info("Executing timeBreachedTask");
                    timeBreachedTask.call();
                    LOGGER.info("Finished timeBreachedTask");
                } catch (Exception e) {
                    LOGGER.error("timeBreachedTask exception", e);
                }
            }
            return;
        }
        try {
            Thread.sleep(10);
        }
        catch (InterruptedException t) {}
    }

}

}

OriginalL'auteur Abax

Je sens l'approche acceptée réponse est un peu dépassé. Avec Java8, il peut être fait beaucoup plus simple.

Dire, vous avez une méthode

MyResult conjureResult(String param) throws MyException { ... }

alors vous pouvez le faire (continuer à lire, c'est juste pour montrer l'approche):

private final ExecutorService timeoutExecutorService = Executors.newSingleThreadExecutor();

MyResult conjureResultWithTimeout(String param, int timeoutMs) throws Exception {
    Future<MyResult> future = timeoutExecutorService.submit(() -> conjureResult(param));
    return future.get(timeoutMs, TimeUnit.MILLISECONDS);
}

bien sûr, jetant Exception est mauvais, ici est la bonne version étendue avec une bonne erreur de traitement, mais je vous suggère d'examiner attentivement, vous voulez faire certaines choses différemment (enregistrement, de retour de délai d'attente dans de longues résultat, etc.):

private final ExecutorService timeoutExecutorService = Executors.newSingleThreadExecutor();

MyResult conjureResultWithTimeout(String param, int timeoutMs) throws MyException {
    Future<MyResult> future = timeoutExecutorService.submit(() -> conjureResult(param));
    try {
        return future.get(timeoutMs, TimeUnit.MILLISECONDS);
    } catch (InterruptedException e) {
        //something interrupted, probably your service is shutting down
        Thread.currentThread().interrupt();
        throw new RuntimeException(e);
    } catch (ExecutionException e) {
        //error happened while executing conjureResult() - handle it
        if (e.getCause() instanceof MyException) {
            throw (MyException)e.getCause();
        } else {
            throw new RuntimeException(e);
        }
    } catch (TimeoutException e) {
        //timeout expired, you may want to do something else here
        throw new RuntimeException(e);
    }
}

OriginalL'auteur Alex Pakka

Vous devez vous connecter pour publier un commentaire.