在后台线程内终止长时间运行的任务

Question

我有一个压缩图像的任务，它在图像中使用了许多循环：

private void writeCompressedData() {
    int i, j, r, c, a, b;
    loat[][] inputArray;

    for (r = 0; r < minBlockHeight; r++) {
        for (c = 0; c < minBlockWidth; c++) {
            xpos = c * 8;
            pos = r * 8;
            for (comp = 0; comp < jpegObj.numberOfComponents; comp++) {
                inputArray = (float[][]) jpegObj.components[comp];

                 for (i = 0; i < jpegObj.VsampFactor[comp]; i++) {
                     for (j = 0; j < jpegObj.HsampFactor[comp]; j++) {
                         xblockoffset = j * 8;
                         yblockoffset = i * 8;
                         for (a = 0; a < 8; a++) {
                             for (b = 0; b < 8; b++) {
                                 // Process some data and put to inputArray
                             }
                         }

                         // Encode Huffman block 
                     }
                 }
             }
         }
     }
}

我在普通线程中运行此方法，如下所示：

new Thread(new Runnable() {
    @Override
    public void run() {
        writeCompressedData();
    }
});

或者在后台工作线程中运行

TaskExecutor.queueRunnable(new Runnable() {
    @Override
    public void run() {
        writeCompressedData();
    }
});

问题是：这种方法有时会出错，在接收无效输入时会导致无限循环。在这种情况下，它将永远运行，并损害CPU，即使当设备的屏幕关闭时，这会增加设备的温度（如果我使用工作线程，它还会阻止等待队列中的其他任务）。

我想我需要设置一个超时来终止长时间运行的任务。在正常Java线程中实现这一点的最佳方法是什么？RxJava支持吗？

我知道我需要修复的是“错误”的方法，而不仅仅是终止它。但对于大型应用程序来说，很难控制其他开发人员的代码，我需要做的第一件事就是避免影响用户。

Answer 1

更好的方法是在不同的进程中运行这样的代码。即使进程崩溃，主进程也将不受影响。

Answer 2

您可以使用JavaExecutorService和Future来解决这个问题。请参阅这篇文章。

Answer 3

你需要某种形式的合作取消，比如检查线程。currentThread（）。isInterrupted（）位于一个或多个嵌套循环内。

for (/* ... */) {
    if (Thread.currentThread().isInterrupted()) return;

    for (/* ... */) {

        if (Thread.currentThread().isInterrupted()) return;

        for (/* ... */) {
            // the tightest loop
        }             
    }
}

然后当您运行该方法时，保留Thread/Future并调用中断/取消（true）：

backgroundTask = new Thread(() -> method());
backgroundTask.start();
// ...
backgroundTask.interrupt();

backgroundFuture = executorService.submit(() -> method());
// ...
backgroundFuture.cancel(true);

在RxJava中，这看起来像这样：

backgroundDisposable = Completable.fromAction(() -> method())
.subscribeOn(Schedulers.io()) // dedicated thread recommended
.observeOn(AndroidSchedulers.mainThread())
.subscribe(() -> { /* done */ }, e -> { /* error */ });

// ...
backgroundDisposable.dispose();