如何编写实现Runnable 接口（从ExecutorService 开始）的类的方法来中断线程？
我知道我可以使用Future fut = es.submit(foo);（其中es 是ExecutorService，foo 是我的类的一个实例）然后从应用程序的主函数内部调用fut.cancel(true);，但是如何我应该从类本身内部调用类似的东西吗？
我想在我的 Runnable 类中有一个方法
public void stop() {…}
这样我就可以从任何地方（包括从应用程序的主函数）调用foo.stop()，它就像我使用了Future.cancel 函数一样工作（如果线程正在等待，它必须引发 ÌnterruptedException`获取信号量）。
【问题讨论】：
标签： java multithreading java.util.concurrent
public class MyRunnable implements Runnable {
private Thread currentThread;
@Override
public void run() {
currentThread = Thread.currentThread();
// Do here something interruptible
}
public void interrupt() {
if (currentThread != null)
currentThread.interrupt();
}
}
但正如人们所说，这是一个糟糕的架构，因为您将正在做什么（可运行）与如何完成（执行）的职责混合在一起
【讨论】：
您可以创建自己的类来实现Runnable 以及另一个接口：
public interface StoppableRunnable extends Runnable {
public void stop();
}
并使用这种类型的Runnable，它保证有一个可以调用的stop() 方法。
使用示例：
public MyRunnable implements StoppableRunnable {
private volatile boolean stopped = false;
public void run() {
while(!stopped) { // Do something.... }
}
public void stop() {
stopped = true;
}
}
【讨论】：
你想要做的——在Runnable 中实现stop() 方法——实际上可能会给你的代码结构带来一些混乱。为什么？ Runnable 对象在设计上是包含必须运行的代码的东西。但是添加stop() 方法将超出Runnable 对象的唯一责任：也就是说，您将使其能够控制代码的执行。应该避免这种情况。
这里有个提示：Runnable 中没有 start() 方法。事实上，Thread 类中有一个，并且在 JDK 中引入了Runnable 接口以减少“可运行”代码与控制其执行的对象（实例Thread)。
我的问题是：为什么您对future.cancel() 不满意？您能否在您的设计要求中添加一些精度？
【讨论】：