ExecutorService是一个Java对象,包含托管的线程池,能够为这些线程调度提交的任务。调度策略在多个可用实现中有所不同。
我正在运行一个使用固定线程池的Java应用程序,其中线程用于向外部服务发出HTTP请求。线程池故意过度配置,我想......
我正在玩不同的ExecutorServices来测试他们执行我提交的任务的方式。下面的代码演示了我测试的服务以及他们如何接收任务......
Executor Service:SingleThreadExecutor不会触发runnable对象
我正在尝试使用Java并发包的ExecutorService SingleThreadExecutor执行一个可运行的对象。当我在新的Runnable对象上调用execute一个命令时,它只是跳过...
为什么ForkJoinPool :: shutdownNow返回一个空列表?
ExecutorService有一个方法List shutdownNow()返回等待执行的任务列表。但是,ForkJoinPool始终返回Collection.emptyList()。 ...
除非Thread.sleep(1)放在线程的run()方法中,否则超过2个线程的工作速度比1或2个线程慢
我正在尝试实现的任务是使用多个线程在设置间隔中查找数字的Collat z序列,并查看与一个线程相比获得了多少改进。不过一个......
我有一个场景,我必须轮询远程服务器检查任务是否已完成。一旦有,我会进行不同的调用以检索结果。我原本以为我应该用...
使用@PreDestroy关闭@Bean ExecutorService
我有一个Spring @Configuration类,如下所示:@Configuration public class ExecutorServiceConfiguration {@Bean public BlockingQueue queue(){return ...
执行新的runnables时丢失ApplicationContext
我知道我是这个春天的新手,但我整天都被困在这里。我不太喜欢提问,但也许我会得到一个想法。所以这是我的问题:我正在尝试为...创建一个队列
似乎不可能创建一个缓存的线程池,它可以创建的线程数限制。以下是在标准Java中实现静态Executors.newCachedThreadPool的方法......
我有关于ThreadPoolExecutor的这个相当简单的问题。我有以下情况:我必须从队列中使用对象,为它们创建适当的工作者任务并将它们提交给...
我在一个函数中有一个循环函数,我打算并行化但不确定多个线程的负载是否会超重并发的好处。我只需发送......
我正在尝试为100个任务运行执行程序。目前,它正在处理10个任务,但是当我发送一个包含11个任务的请求时,1个将失败(任何超过10个的任务都将失败)。当我调试它时,我意识到......
我有一个简短的java程序,它创建了一个单线程计划执行程序,我安排了一个任务。 ScheduledExecutorService scheduledExecutorService = Executors.newSingleThreadScheduledExecutor(); ...
我运行此过程来下载一些数据并将它们插入数据库。整个过程大约需要5分钟。我注意到在下载时,当手机锁定屏幕时......
我有两个API:一个启动线程,另一个停止线程。我通过调用/ start API成功启动了一个线程,但是我无法通过调用/ stop API来停止已经运行的线程。 ...
ExecutorService与CompletableFuture
我一直在尝试实现一个异步过程,其中父方法调用一个子方法,然后调用三个不同的方法。我希望所有这一切都完成......
在将此标记为重复之前,请仔细阅读该问题。下面是伪代码的片段。我的问题是 - 下面的代码是否没有打败并行异步的概念......
我有Arquillian和ManagedExecutorServices的问题。 Arquillian无法找到默认的ManagedExecutorService。异常是:引起:javax.naming.NameNotFoundException:否...
这是顺序循环:private boolean canSpawnVehicle(SpawnPoint spawnPoint){// TODO:可以更快。 Rectangle2D noVehicleZone = spawnPoint.getNoVehicleZone(); for(VehicleSimView ...
如果调用scheduleWithFixedDelay方法多于池大小,ScheduledExecutorService如何工作?
在这段代码中,我使用5个线程的池创建ScheduledExecutorService并调用scheduleWithFixedDelay方法5个时间。它将创建5个调度程序,每个调度程序将调用testBean :: test每个...