Java利用异常中断当前任务的技巧分享

更新时间：2023年08月28日 14:05:26 作者：乐征skyline

在日常开发中,我们经常遇到调用别人的代码来完成某个任务,但是当代码比较耗时的时候,没法从外部终止该任务,所以本文为大家介绍了如何利用异常中断当前任务,需要的可以参考下

Java小技巧：利用异常中断当前任务

在日常开发中，我们经常遇到调用别人的代码来完成某个任务，但是当代码比较耗时的时候，没法从外部终止该任务。有些程序从开始就考虑到了这个场景，就会提供对应的cancel或stop之类的方法用于终止任务，但还是会有很多三方库并没有提供响应接口。比如，下面这个下载示例：

class DownloadTask {
    public void download(Listener listener) {
        try {
            for (int i = 0; i < 100; i++) {//模拟下载过程
                Thread.sleep(1000);
                listener.onProgressUpdated(i + 1);
            }
            listener.onCompleted();
        } catch (InterruptedException e) {
            throw new RuntimeException(e);
        }
    }
    public interface Listener {
        void onProgressUpdated(int progress);
        void onCompleted();
    }
}
public class Main {
    public static void main(String[] args) throws InterruptedException {
        DownloadTask task = new DownloadTask();
        task.download(new DownloadTask.Listener() {
            @Override
            public void onProgressUpdated(int progress) {
                System.out.println("onProgressUpdated: " + progress);
                if (isInterrupted.get()) {
                    throw new EndException();
                }
            }
            @Override
            public void onCompleted() {
            }
        });
    }
}

这里的DownloadTask开始运行后，就无法直接停止。如果DownloadTask是第三方库的代码时，我们可能不方便改它的代码使其支持中断。本文介绍一种利用异常来终止这样的任务的方法。

（注：本文介绍的方法仅限于单线程或单个子线程的情况，并且需要有在任务运行的线程执行代码的能力，比如回调）

场景1：任务没有另起线程的情况

这个就是上面展示的那个下载示例，我们可以通过回调，直接利用异常中断该任务：

//DownloadTask 同上
public class Main {
    private static volatile boolean isInterrupted;
    public static void main(String[] args) throws InterruptedException {
        new Thread(() -> {//模拟外部调用，5秒后通过设置isInterrupted来取消任务，也可以把这段代码放到一个新的cancel方法中
            sleep(5000);
            isInterrupted = true;
        }).start();
        try {
            DownloadTask task = new DownloadTask();
            task.download(new DownloadTask.Listener() {
                @Override
                public void onProgressUpdated(int progress) {
                    System.out.println("onProgressUpdated: " + progress);
                    if (isInterrupted) {
                        throw new EndException();
                    }
                }
                @Override
                public void onCompleted() {
                    System.out.println("onCompleted...");
                }
            });
        }catch (EndException e){
            System.out.println("end...");
            //is interrupted, ignore
        }
        Thread.currentThread().join();
    }
    static class EndException extends RuntimeException {
    }
    public static void sleep(long time) {
        try {
            Thread.sleep(time);
        } catch (InterruptedException e) {
            throw new RuntimeException(e);
        }
    }
}

场景2：任务另起子线程的情况

如果任务另起子线程来执行，那么就没法直接用try-catch来捕获异常，那么就得通过线程的UncaughtExceptionHandler来完成。假如下载的代码是这样的：

public class DownloadTask {
    public void download(Listener listener) {
        new Thread(() -> {
            try {
                for (int i = 0; i < 100; i++) {//模拟下载过程
                    Thread.sleep(1000);
                    listener.onProgressUpdated(i + 1);
                }
                listener.onCompleted();
            } catch (InterruptedException e) {
                throw new RuntimeException(e);
            }
        }).start();
    }
    public interface Listener {
        void onProgressUpdated(int progress);
        void onCompleted();
    }
}

那么外部调用并终止的代码就是：

public class Main {
    private static volatile boolean isInterrupted;
    public static void main(String[] args) throws InterruptedException {
        Thread.UncaughtExceptionHandler handler = (t, e) -> {
            if(e instanceof EndException){
                System.out.println("end...");
                //is interrupted, ignore
            }
        };
        DownloadTask task = new DownloadTask();
        task.download(new DownloadTask.Listener() {
            @Override
            public void onProgressUpdated(int progress) {
                System.out.println("onProgressUpdated: " + progress);
                if(Thread.currentThread().getUncaughtExceptionHandler() != handler){//注意这里
                    Thread.currentThread().setUncaughtExceptionHandler(handler);
                }
                if (isInterrupted) {
                    throw new EndException();
                }
            }
            @Override
            public void onCompleted() {
                System.out.println("onCompleted...");
            }
        });
        sleep(5000);
        isInterrupted = true;
        Thread.currentThread().join();
    }
    public static class EndException extends RuntimeException {
    }
    public static void sleep(long time) {
        try {
            Thread.sleep(time);
        } catch (InterruptedException e) {
            throw new RuntimeException(e);
        }
    }
}

写在最后

大家也能看到，这并不是什么万能的方法，甚至有很大局限，但碰到合适的场景还是可以通过简短的代码来解决问题。

到此这篇关于Java利用异常中断当前任务的技巧分享的文章就介绍到这了,更多相关Java中断任务内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家！

您可能感兴趣的文章:

java
异常

Netty 轻松实现文件上传功能
今天我们来完成一个使用netty进行文件传输的任务。在实际项目中，文件传输通常采用FTP或者HTTP附件的方式，对Netty 文件上传功能感兴趣的朋友一起看看吧
2021-07-07
Spring Framework六种常见设计模式
设计模式是软件开发的重要组成部分，本文借助spring来讲解这个框架的设计模式，通过本文我们探讨了spring如何利用这些模式来提供这些丰富的功能，对本文感兴趣的朋友跟随小编一起看看吧
2023-06-06
Java中RedisUtils工具类的使用
本文主要介绍了Java中RedisUtils工具类的使用，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧
2022-07-07
MyBatis-Plus插件机制及通用Service新功能
这篇文章主要介绍了MyBatis-Plus插件机制以及通用Service、新功能,本文通过实例图文相结合给大家介绍的非常详细，对大家的学习或工作具有一定的参考借鉴价值，需要的朋友可以参考下
2022-07-07
23种设计模式（4） java生成器模式
这篇文章主要为大家详细介绍了23种设计模式之java生成器模式，具有一定的参考价值，感兴趣的小伙伴们可以参考一下
2017-11-11
Java架构设计之六步拆解 DDD
DDD（Domain-Driven Design 领域驱动设计）是由Eric Evans最先提出，目的是对软件所涉及到的领域进行建模，以应对系统规模过大时引起的软件复杂性的问题
2022-02-02
QR 二维码中插入图片实现方法
这篇文章主要介绍了QR 二维码中插入图片实现方法的相关资料,需要的朋友可以参考下
2016-11-11
SpringCache缓存自定义配置的实现
本文主要介绍了SpringCache缓存自定义配置的实现，文中通过示例代码介绍的非常详细，具有一定的参考价值，感兴趣的小伙伴们可以参考一下
2022-01-01
根据ID填充文本框的实例代码
这篇文章介绍了根据ID填充文本框的小例子，有需要的朋友可以参考一下
2013-07-07
Java检测网络是否正常通讯
在网络应用程序中，检测IP地址和端口是否通常是必要的，本文主要介绍了Java检测网络是否正常通讯，具有一定的参考价值，感兴趣的可以了解一下
2023-11-11