我应该在 Future 上调用 cancel(true) 吗？或者我自己的 FutureTask
我有一个自定义类 MyFutureTask extends FutureTask ，我在该类的 done() 方法上执行了一些代码。 我使用 ExecutorService，将其称为 submit(new MyFu…
ExecutorService 仅运行最近添加的 Callable
我有一个单线程执行器服务，用于通过网络获取一些数据。 当用户在搜索框中输入内容时，我正在对可能的网络任务进行排队。我想要的是取消所有以前的请…
我需要澄清 ThreadpoolExecutor beforeExecute 和 afterExecute 挂钩
我在我的应用程序中使用线程池。我已经对 TreadPoolExecutor 进行了子类化，并重写了 beforeExecute、afterExecute 和终止方法以用于统计目的。 我还…
生产者消费者 - 使用 Executors.newFixedThreadPool
我对生产者-消费者模式的理解是，它可以使用生产者和消费者之间共享的队列来实现。生产者将工作提交到共享队列，消费者检索并处理它。也可以通过生产…
ThreadPoolExecutor 线程与其他线程存在争用
我正在致力于对现有 Java 应用程序进行增强。该应用程序是一个消息处理器，每天处理数百万条消息。它基本上是使用 Core Java 编写的，线程和队列是使…
如果出现问题并且我想重试，使用相同的 Executor 重新排队 Runnable 是否安全或明智？
我刚刚在我的 runnable 的 run() 方法中编写了这段代码： try { dbConnection = MyApp.datasource.getConnection(); } catch (SQLException e) { logg…
有没有一种简单的方法来判断 Java 执行器在给定时刻正在运行哪些任务？
我确信我可以将一些东西组合在一起，这将使我能够解决这个问题，但我希望有一个我所缺少的开箱即用的解决方案。我阅读了文档，但没有看到任何内容。 …
执行器运行时间超过超时值
这是scala的一段代码。我将超时设置为 100 mills。在 10000 个循环中，有 106 个循环运行超过 100 个工厂而没有抛出异常。最大的工厂甚至有 135 家。…
Java 线程或执行器帮助：同时执行多个 MySQL 选择、插入和更新
我正在编写一个应用程序来分析 MySQL 数据库，并且需要同时执行多个 DML；例如： // In ResultSet rsA: Select * from A; rsA.beforeFirst(); while (…
FutureTasks 和 CachedThreadPool 如何工作
我目前有执行以下操作的代码： private final static ExecutorService pool = Executors.newCachedThreadPool(); public void foo(){ FutureTask firs…
- 共 1 页
- 1
