在Java / Kotlin的ThreadPool中取消被取代的任务

我试图找出如何取消一个任务在一个ThreadPool如果一个新的任务来取代它。 我有一些类似这样的：

 class RenderableThing { private val lock = ReentrantLock() fun lock(interrupt: Boolean) { if (lock.isLocked && interrupt) { // How do I interrupt the thread that has the lock? } lock.lock() } fun unlock() = lock.unlock() fun cache() = Cached() inner class Cached() } class BackgroundStuff(threads: Int) { val pool = Executors.newFixedThreadPool(threads)!! fun doBackgroundStuff(thing: RenderableThing): Future<Stuff> { val cache = thing.cache() return pool.submit { try { thing.lock() // Do long running I/O task on cache } finally { thing.unlock() } } } } 

但是，如果相同的RenderableThing被提交给doBackgroundStuff （已经做了更改并且需要保存到磁盘），我希望能够取消之前提交的Future （因为它现在已经过期，被覆盖，没有理由等待它完成了）。 问题是，锁定发生在未来还不存在的内部。

我知道你永远不应该强制杀死一个锁定的线程（我什至不知道如何，因为它是一个ReentrantLock ），那么这是做什么正确的方法？

编辑 ：我的问题是不同的，因为我没有进入将来取消它（锁没有放置到位，直到ThreadPool拿起，到这一点的thing可能已提交多次，我不知道哪一个会拥有锁）。 如果我这样做，将是一块蛋糕（处理中断的代码已经到位）。 我应该如何改变我的代码来获得对拥有锁的未来（甚至线程）的引用？

Answer 1

我只是想知道这段代码是否工作：

 //... fun doBackgroundStuff(thing: RenderableThing): Future<Stuff> { LLget(thing)?.cancel(true) val cache = thing.cache() val f = pool.submit { try { thing.lock() // Do long running I/O task on cache } finally { thing.unlock() } } LLput(thing, f) return f } //... object L { val L: IdentityHashMap<RenderableThing, Future<Stuff>> ? = IdentityHashMap<>() }