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

Question

我想知道如何取消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），那么做到这一点的正确方法是什么？

编辑：我的问题是从this one不同的，因为我没有进入未来取消它（锁不到位，直到ThreadPool它捡起，并通过该点的thing可能已经提交了多次，我不知道哪个会拥有锁）。如果我这样做了，那将是小菜一碟（处理中断的代码已经到位）。我应该如何更改我的代码以获取对拥有锁的未来（甚至线程）的引用？

Answer 1

我只是想知道，如果这一块的代码工作：

//... 
fun doBackgroundStuff(thing: RenderableThing): Future<Stuff> { 
    L.L.get(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() 
     } 
    } 
    L.L.put(thing, f) 
    return f 
} 
//... 

object L { 
    val L: IdentityHashMap<RenderableThing, Future<Stuff>> ? = IdentityHashMap<>() 
}