對事件流進行大量處理的最後結果

Question

有一系列事件正在由一個執行很長時間的昂貴算法進行處理。除了最後（每時每刻）以外的所有事件的結果都是沒有意義的。我想處理事件，每當新事件到達時，都會異步中斷前一事件的處理。

有沒有什麼好的模式或技術可以這樣做？

我認爲：

• 參與者（沒有取消）
• 期貨（沒有取消）
• 線程（不清楚應該如何持續事件進行選擇，他們通常重）
• 線程池（需要定製的解決方案，不是斯卡拉方式？）

我傾向於選擇池，具有自定義可中斷的tasklet （尚未設計）。 Scala中有更好的選擇嗎？如果不是我應該如何實現我的tasklet？

Answer 1

我可以建議的唯一的事情就是使用Java期貨並在Java未來上調用cancel。然後，您需要處理InterruptedException（用於阻止操作）並定期檢查Thread.isInterrupted（用於計算密集型操作）。我想你已經知道了。