如何在JavaEE中执行响应后的代码
我试图找到一种在响应后运行代码的方法，但未成功. 在我的情况下，服务器向我发送数据以便让我完成工作，但是此操作可能会很长(例如，向5000个联系人发送SMS并检查谁收到了该消息).服务器期望HTTP 204 No Content立即响应，以确保已接收到数据.然后，我的web应用将执行操作并通过REST API发送状态. 我的问题是:如何发送响应然后执行代码? 现在我尝试:
..
executorservice相关内容
如何知道ES上的项目可以重新提交给ES的ExecutorService完成时间
我的Java应用程序可处理文件夹中的音乐文件，它旨在并行且独立地处理多个文件夹.为此，每个ExecutorService都将处理每个文件夹，该ExecutorService的最大池大小与计算机的CPU数量不匹配. 例如，如果我们有8个CPU的计算机，则(理论上)可以同时处理八个文件夹，如果我们有16个CPU的计算机，则可以同时处理16个文件夹.如果只有1个CPU，则将pool-size设置为
..
在用户输入上设置超时
我正在尝试使用以下代码在Java控制台应用程序中为用户输入设置超时 ExecutorService executor = Executors.newSingleThreadExecutor(); Callable task =() -> { System.out.print("input: "); BufferedReader br = new BufferedReader
..
关机还是不关机?在ExecutorService(Java8)中
我试图了解执行程序服务相对于关机的行为.该文档说，除非有shutdown()调用，否则应用程序不会终止-但是在此简单示例中.恰好在一分钟后退出.有什么主意吗? Runnable r = new Runnable() { @Override public void run() { Print.println("d
..
将来的任务完成后，Java Process没有退出
这是我使用Future的代码段. import java.util.concurrent.*; import java.util.*; public class FutureDemo{ public FutureDemo(){ /* Future */ ExecutorService service = Executors.new
..
检测当前线程是否为ExecutorService线程
我想确保我的类的所有方法(更新程序服务)都在ExecutorService的线程中调用(假设甚至只有一个线程).没有给出方法的顺序，因此可以从Executor的线程和其他一些线程(主要是GUI线程)中调用那些公共的方法. 我的代码: // Instantiated lazy using synchronized getter - I decided not to bother wi
..
从期货中获取值时，为什么会收到NullPointerException?
我正在使用ExecutorService和ExecutorService同时运行某些Callables.这是我的代码的简化版本: ArrayList objResults = new ArrayList(); ExecutorService esrExecutor = Executors.newFixedThreadPool(2); Set
..
我应该在请求中创建executorService还是在Web应用程序中共享一个实例?
我正在向基于Jersey的Web服务添加新的端点.支持端点的逻辑需要对另一个服务进行10到50次调用.这些调用是独立的并且可以并行化，因此我在考虑使用执行程序服务在多个线程之间分配工作. 我想知道应该为每个请求实例化executorService还是在Web应用程序中共享一个executorService实例.在后一种情况下，我将如何确定它应运行的线程数? 解决方案 我想知道是否
..
使用ExecutorService和BlockingQueue锁定可运行(停车)
注意:我了解规则网站，但不能输入所有代码(复杂/大代码). 我放了一个不同的(所有真实代码都太多了，您不需要在这里) 请不要向我推荐此代码的另一个jar或外部库. 我希望我更具体一些，但是我不知道要提取和显示哪个部分. 在您关闭此问题之前:显然，如果有人告诉我要去哪里看(技术细节)，我愿意完善我的问题. 我制作了视频，以显示我的问题. 即使提出问题，我也画了一个图来说明情况
..
Tomcat 7和ScheduledExecutorService.shutdown
我正在使用ScheduledExecutorService运行计划的线程. 我实现了ServletContextListener.contextDestroyed并调用了ScheduledExecutorService.shutdownNow和awaitTermination. 这里是一个例子: @Override public void contextDestroyed(Servl
..
什么终止了我的Java ExecutorService
我最初用一个更复杂的子类看到了这个问题，但是我已经简化了，所以现在只包含了一些其他调试功能，并且仍然遇到相同的问题. import com.jthink.songkong.cmdline.SongKong; import com.jthink.songkong.ui.MainWindow; import com.jthink.songkong.util.SongKongThreadFacto
..
ScheduledExecutorService:何时应调用关机?
我在应用程序中使用 ScheduledExecutorService .我需要在某些Utility类中不时使用它来运行计划的线程. 将 ScheduledExecutorService 保留在静态字段中是否是一个好的设计?在这种情况下是否必须调用ScheduledExecutorService.shutdown()?如果不调用关机会有什么风险? 这就是我想做的: private
..
Java:带有可调用对象的ExecutorService:invokeAll()和future.get()-结果顺序正确吗?
我使用Java中的ExecutorService通过invokeAll()调用线程.之后，用future.get()获得结果集.以创建线程的相同顺序接收结果非常重要. 这是一个代码段: try { final List threads = new ArrayList(); // create threads for (String name : collect
..
知道所有线程何时完成并处理异常
我正在使用Executor框架使用线程池(即newFixedThreadPool)启动多个线程.我使用threadpool.submit(aThread)提交要由线程池执行的作业，这可以正常工作，但是我需要确定所有线程何时完成，以便我可以继续进行其他处理.我看着使用Future.get()阻塞直到线程完成为止，这里的问题是它阻塞直到有结果为止.我还研究了使用连续调用isTerminated()方法
..
ExecutorService JVM不会终止
我不明白为什么我必须调用executorService.shutdown() 明确终止executorService. 如果我不调用shutdown()，那么JVM将不会自行终止. 我的程序有什么问题或缺少什么概念? public class ExecutorServiceExample { public static class Task1 implements Ru
..
如何对在执行程序服务中运行的代码段进行单元测试，而不是在Thread.sleep(time)上等待
如何对在执行程序服务中运行的代码进行单元测试? 就我而言， public void test() { Runnable R = new Runnable() { @Override public void run() { executeTask1(); executeTask2(); }
..
针对消费者生产者使用ExecutorService和PipedReader/PipedWriter(或PipedInputStream/PipedOutputStream)的Java示例
我正在寻找一个简单的生产者-Java中的使用者实现，并且不想重新发明轮子 我找不到同时使用新的并发包和两个Piped类的示例 是否有一个同时使用 PipedInputStream 以及为此使用的新Java并发包? 是否有一种更好的方法，而无需将Piped类用于此类任务? 解决方案 对于您的任务，仅使用一个线程并在您从数据库中读取时使用BufferedOutputStrea
..
停止提交给ExecutorService的Runnable
我已经在Java应用程序中实现了订阅.添加新的订户后，应用程序将创建新任务(实现Runnable的类以在单独的线程中运行)并将其添加到ExecutorService中，例如: public void Subscribe() { es_.execute(new Subscriber(this, queueName, handler)); } //... private Execut
..
executorService.submit(Runnable)返回的将来对象是否持有对可运行对象的任何引用?
假设我们有以下代码: List> runningTasks; ExecutorService executor; ... void executeTask(Runnable task){ runningTasks.add(executor.submit(task)); } 我的问题是: runningTasks是否保存对task对象的引用? 将其保存多
..
ExecutorService在调用线程中运行任务?
是否有任何java.util.ExecutorService实现仅在调用线程中运行所有已执行的任务?如果默认情况下Java中未包含此代码，是否有一个包含此类实现的库? 解决方案 我能找到的唯一现有实现是在此处粘贴源代码(不带注释)以供将来参考: package org.apache.camel.util.concurrent; import java.util.List; impo
..