我尝试使用concurrecy发送未定义数量的HTTP Rest请求。这是基本的代码框架：PoolingHttpClientConnectionManager connManager = new PoolingHttpClientConnectionManager(CloseableHttpClient httpclient = HttpClients.custom().setConnectionManager(connManager).build();
ExecutorServicees.awa
浏览 2提问于2017-01-19得票数 0
我正在构建一个部署在WebLogic12c上的spring boot rest api应用程序。我的一个需求是对每个传入的请求运行一些长时间运行的任务。传入的rest请求可能会导致多个异步任务执行。-")); 然后，对于我在控制器中收到的传入请求，运行两个for循环，并将这些任务分配给ExecutorService： for (final String
浏览 23提问于2019-06-21得票数 3
回答已采纳
在没有spring框架的情况下，我用核心java编写了所有核心实现。我在这个春季引导应用程序中使用那个罐子。我想管理我的rest控制器的并发性。理想情况下，我只想让两个并发请求进入execute()方法，我对Async进行了注释。我一次测试两个并发请求，但我在日志中看到我的请求同时进入execute()。所有的任务都是内存密集型的。(futureTarget);
executorService.shu
浏览 2提问于2017-09-11得票数 1
我正在向Spark job Server发出rest请求，以获取该作业的状态。代码如下： ExecutorService executorService= Executors.newSingleThreadExecutor();
Future<JobResult> resultFuture = executorServic
浏览 0提问于2016-12-22得票数 1
2回答
在花了一天时间学习java并发性API之后，我仍然不太明白如何在CompletableFuture和ExecutorService类的帮助下创建以下功能：
异步任务完成后，我需要将HTTP请求(带有有效负载，REST调用方给我的)发送到我从作业中获得的URL。理想情况下，我有一些同步计数器，它
浏览 1提问于2018-05-07得票数 1
回答已采纳
3回答
我有一个JAX/泽西Rest，它得到一个请求，需要在一个单独的线程中做一个额外的工作，但是我不确定是否应该使用一个线程池。我希望对这个API有很多请求(每天有几千个请求)，但我在后台只有一个额外的工作。
每一次都创建一个新的线程会不会很糟糕？如有任何建议，将不胜感激。我以前没有用过ThreadPool。我只需要在后台运行一个额外的作业。这项工作将调用另一个API来记录一些信息，仅此而已。但它必须对每一项请求
浏览 11提问于2015-07-29得票数 2
回答已采纳
我试图使用Java的ExecutorService发送并发REST请求，这些请求生成各种系统信息日志(来自控制器)，但是遇到了错误。我的请求中大约有一半成功地到达了目标，但另一半似乎被发送了，但没有在发送到的服务器上找到。我想我在设置ExecutorService的逻辑上可能有一个缺陷。下面显示的函数log()可以从对控制器的REST调用中调用，并且应该创建一个发
浏览 2提问于2016-06-27得票数 0
回答已采纳
我使用AsyncHttpClient和Netty在微服务之间执行非阻塞REST调用。当Netty线程返回到池中时，我正在试图找出如何清除threadLocal值。具体来说，我存储与请求链关联的ID，以帮助在服务之间关联日志消息。一旦执行了工作线程并返回到线程池，我需要清除这个threadLocal数据。但是，我找不到这方面的任何钩子。我认为创建自己的ExecutorService来重写afterExecute(Runnable r，Throwable t)并通过我<em
浏览 4提问于2016-04-17得票数 1
回答已采纳
1回答
在一个REST服务器和5个工作机器集群上部署Hazelcast的正确方法是什么？我应该启动Hazelcast 5个服务器实例(每个工作人员一个)和REST服务器上的一个HazelcastClient吗？我有过
一个集群中有五台工作机器，每台机器都在本地文件系统中保存一些数据。用户请求将被REST服务器机器接受，而REST服务器将向集群中的每个工作人员发送搜索MultiT
浏览 1提问于2017-03-08得票数 3
回答已采纳
跟踪工作(单个组件跟踪)，但uber- Trace -id不与rest请求头部一起传递，因此下一个微服务( rest请求的接收者)将从零开始生成跟踪，而不包含span信息。(new TracedExecutorService(executorService, tracer)).register((new Builder(tracer)).withTraceSerialization的文件META-INF/services/org.eclipse.mi
浏览 80提问于2021-02-05得票数 2
我正在尝试同时向rest发送一些文件。执行此操作时，第一个文件的发送次数与我在Executors.newFixedThreadPool()方法中分配的线程数完全相同。如果我分配了5个线程，那么第一个文件(每次执行中的不同)会被发送5次，而其余的文件只发送一次！对于10个线程，它被发送了10次！
如何只发送一个文件多次，而rest不发送？我在代码上做错了什么？编辑：我要发送文件的api是在Tomcat 8上使用Jersey。以下是文件<
浏览 0提问于2018-04-19得票数 0
回答已采纳
我在部署在Wildfy 21上的JavaEE Web应用程序中使用托管执行器服务。目标是在其他线程中执行一个长时间任务，以便释放服务器用于响应客户端请求的线程(HTTP请求)。我使用的是在Wildfly中配置的默认executor服务：publicvoid set
浏览 4提问于2021-01-22得票数 0
我在代码中创建了多个ExecutorService实例，通常每个UI页面都有一个ExecutorService实例。每个ExecutorService实例将执行一些http get请求线程。private ExecutorService m_threadPool = Executors.newCachedThreadPool();
这样做可以吗？我遇到的问题是，有时http get请求会从HttpURLConnection getResponseCod
浏览 0提问于2010-06-04得票数 4
回答已采纳
我有以下场景，
对于tomcat上的每个请求，我们需要从不同的机器获取数据(这里我们已经在每台机器上提供了rest服务)，并且作为响应，我们向该请求发送来自不同机器的所有响应的合并数据。为此，我们实现了ExcuterServices，如下所示
ExecutorService executor = Executors.newFixedThreadPool(numThreads);List<Future<Object>> re
浏览 0提问于2015-10-16得票数 0
SOAP客户端将向Webservice发送消息，Webservice验证消息并将确认作为服务的响应发送。但是，应该在后台执行一个SocketConnection，以进一步异步地处理消息。提供的实现是在后台使用ChildThread生成一个ExecutorService.newFixedThreadPool。这是正在使用的代码(并不是webservice实现文件的所有代码都在这里发布)。不过，你能帮我做以下的查询吗？
由于后台线程的活动时间很长，这是
浏览 3提问于2015-10-21得票数 2
我正在使用Spring和泽西一起创建REST服务，我有一个用例，对于我收到的每一个请求，我都需要对一个上游API进行几次调用(N)。我得到一个请求，它有n个条目，对于每个条目，我创建一个线程来调用我的依赖项(REST)并处理响应。最后，我收集所有的响应，维护订单，并将它们作为单个响应返回给客户端。我使用的是Java 8的CompletableFuture，我想知道我是否正确地使用了ExecutorService框架。@Componen
浏览 3提问于2017-04-02得票数 3
回答已采纳
2回答
假设我有一个简单的例子： public static void main(String[] args) { }
System.out.println("rest od code..");singleThreadExecutor，所以1线程应该执行5任务。我原以为我<em
浏览 3提问于2020-09-15得票数 0
回答已采纳
我正在使用ExecutorService(全局声明)同时运行多线程。ExecutorService需要一个小时才能完成任务。因此，我需要获得当前运行的线程详细信息，如活动线程，排队线程和已完成线程。当我杀死ExecutorService时，ExecutorService杀死了但是线程在后台运行。因此，在关闭ExecutorService之前，我需要从ExecutorService中获取线程对象，并使用循环或迭代器手动关闭线程。ExecutorServi
浏览 7提问于2016-11-28得票数 1
云服务器
ICP备案
实时音视频
即时通信 IM
对象存储
腾讯云开发者
