在我的应用程序中，我对一些本机代码进行了包装，这是通过JNI桥调用的。此本地代码需要在单独的线程中执行（并行处理）。但是，问题在于代码有时“挂起”，因此线程需要“强制”终止。不幸的是，我还没有找到任何“微妙的”方法来这样做：一般建议是告诉线程中的代码正常退出，但是我无法使用此本地代码（以上均为第三方代码）来执行此操作。

我使用Java Concurrent API进行任务提交：

Future<Integer> processFuture = taskExecutor.submit(callable);

try {
    result = processFuture.get(this.executionTimeout, TimeUnit.SECONDS).intValue();
}
catch (TimeoutException e) {
    // How to kill the thread here?
    throw new ExecutionTimeoutException("Execution timed out (max " + this.executionTimeout / 60 + "min)");
}
catch (...) {
    ... exception handling for other cases
}

Future#cancel()只会中断线程，但不会终止线程。因此，我使用了以下技巧：

class DestroyableCallable implements Callable<Integer> {

    private Thread  workerThread;

    @Override
    public Integer call() {
        workerThread = Thread.currentThread();

        return Integer.valueOf(JniBridge.process(...));
    }

    public void stopWorkerThread() {
        if (workerThread != null) {
            workerThread.stop();
        }
    }
}

DestroyableCallable callable = new DestroyableCallable();

Future<Integer> processFuture = taskExecutor.submit(callable);

try {
    result = processFuture.get(this.executionTimeout, TimeUnit.SECONDS).intValue();
}
catch (TimeoutException e) {
    processFuture.cancel(true);
    // Dirty:
    callable.stopWorkerThread();

    ThreadPoolTaskExecutor threadPoolTaskExecutor = (ThreadPoolTaskExecutor) taskExecutor;

    logger.debug("poolSize: " + threadPoolTaskExecutor.getPoolSize() + ", maxPoolSize:"
                    + threadPoolTaskExecutor.getMaxPoolSize() + ", activeCount:"
                    + threadPoolTaskExecutor.getActiveCount());
    }

    throw new ...;
}
catch (...) {
    ... exception handling for other cases
}

与此代码有关的问题/问题：

• 通常这样做是否正确？还有其他更优雅的选择吗？
• activeCount 任务执行程序上的操作没有减少，因此任务执行程序仍然“认为”线程正在运行
• 我不得不在方法上添加workerThread != null检查stopWorkerThread()，因为这个变量null在某些情况下是存在的。我不明白这些情况是什么…

笔记：

• 本机代码不占用文件描述符（套接字）。一切都作为数据块传递给它，并以相同的方式返回。
• 本机代码占用大量CPU。即使保证终止，也可能需要很长时间。

赏金编辑 ：重新访问本机代码的方法/建议很明确，请不要在答复中提供。我需要纯Java解决方案/解决方法。