ExecutorService是一个Java对象,包含托管的线程池,能够为这些线程调度提交的任务。调度策略在多个可用实现中有所不同。
java.util.concurrent.Future.get() 不返回
我有以下Java代码: 最终未来未来 = exeService.submit( 新的可运行(){ 公共无效运行(){ myObject.doSomething(); } } ); future.get(); 哪里
我正在尝试执行以下并发代码,但并发线程永远不会响应。创建 10 个并行线程和控件后,请找到下面的伪代码...
如何等待使用不同`ExecutorServices`创建的`Future`列表
好的,所以我知道这里的第一个答案/评论将是“使用一个 ExecutorService 并使用 invokeAll”。然而,我们保留线程池有一个很好的理由(我不会让人们感到厌烦)
我们使用具有以下机制的异步 servlet(异步 servlet 不异步操作) @WebServlet(urlPatterns = { "/test" }, asyncSupported = true) 公开课
我们在 Java 17 中有一个服务,它在我们端执行逻辑,将请求发送到第三方系统。第三方系统的响应时间约为800-1400ms。 我们有一个 ThreadPoolExecutor ...
Java:杀死由 ExecutorService 作为 Runnable 启动的线程
我有一个系统,当它收到来自网络服务的调用时,它会启动工作程序。 Worker 由 ExecutorService 启动,启动的类实现 Runnable。但是,如果...
请告诉我如何最好地做到这一点:我有很多对象,大约 200 个,每 20 秒从网络更新一次它们的状态(类似于正在刷新的网页)。每个对象都有 sev...
Java:使用 executorService 运行异步任务
我有两个端点/issue和/callback,调用/issue后会立即调用/callback。在问题中,我向执行者服务提交了一项任务,并将未来存储到地图上,键为 or...
我创建了一个异步任务线程,它为长时间运行的作业创建了内部 8 个工作线程。假设我有 8 个长期运行的作业,一切都工作正常。所有 8 个 Worker-Jobs 在例如 10 秒内完成...
我有一个大约有一千个Java对象的列表,并且正在迭代一个List容器来处理它们,对每个对象进行相同的处理。这种顺序方法需要花费大量时间
导入java.util.concurrent.ExecutorService; 导入java.util.concurrent.Executors; 公共类 MyMainThread { 公共静态无效主(字符串[] args){ ExecutorService 执行器 = Exec...
Executors#newThreadPerTaskExecutor 的需求/使用是什么?
我浏览了一些最近引入的公共 API,并偶然发现了 JDK 21+ 中的 Executors.newThreadPerTaskExecutor。 创建一个执行器,为每个任务启动一个新线程。号码 的...
我正在尝试重置计时器,以便它可以从我的数组中提取另一个值。 有谁知道解决方案吗?我的错误是说: 泥炭 = 泥炭 = 1; 从内部类引用的局部变量必须...
我在应用程序中使用执行程序服务从 URL 下载文件。我想添加一个水平进度条来显示下载进度,但我遇到了一些错误。我怎样才能添加进度...
所以,假设我有以下 ScheduledExecutorService: 公共课 Foo { 私有 ScheduledExecutorService 执行; 公共 Foo() { exec = 执行者。
spring 会负责关闭你的 ExecutorService 吗?
在我的配置类中,我有一个固定线程池的 bean @豆 公共ExecutorService固定线程池(){ 返回 Executors.newFixedThreadPool(200); } 我稍后会在某堂课上自动装配它。就像我一样
代码必须做什么: 同步执行 Bot#run。 需要修复什么: 在其他机器人和线程之间共享资源(Bot.responseData 或...更多)。 Bot.run() 执行阶段: http 请求 ->...
向 ExecutorService 提交任务时并行流如何工作?
我是一家软件公司的顾问,负责使用我的开发同事构建的不同工具为我们的客户提供支持。 我对 Java 的经验很少,但我确实尝试阅读代码......
并行流与 ExecutorService 结合使用时如何工作?
我是一家软件公司的顾问,负责使用我的同事开发人员构建的不同工具来支持我们的客户。 我对 java 的经验很低,但我确实阅读了代码试图理解......
我有一个代码块,应该使用 CompletableFuture 和 ExecutorService 在不同线程上并行运行。该代码块发出网络请求(使用 RetroFit),并等待每个