executorservice 相关问题

ExecutorService是一个Java对象,包含托管的线程池,能够为这些线程调度提交的任务。调度策略在多个可用实现中有所不同。

如何在Java中序列化ExecutorService?

我创建了一个CountMinSketch来计算某些值的最小频率。我正在使用ExecutorService异步更新草图。我在我需要的Flink项目中使用这个课程......

回答 2 投票 0

命名ExecutorService的线程和线程池

假设我有一个利用Executor框架的应用程序,如Executors.newSingleThreadExecutor()。submit(new Runnable(){@Override public void run(){// do stuff}} ...

回答 16 投票 193

如果通过启动(调度程序){...}调用CoroutineDispatcher,则如何测试该块是否在CoroutineDispatcher上运行

我们最近开始在Android应用程序上使用协同程序。一切都很好,花花公子,直到有人写了大致相当于以下功能的东西:有趣的例子(调度员:......

回答 1 投票 3

Java中此代码中的ExecutorService.submit和ExecutorService.execute有什么区别?

我正在学习使用ExectorService来池化线程并发送任务。我有一个简单的程序,下面导入java.util.concurrent.ExecutorService; import java.util.concurrent.Executors;导入java ....

回答 7 投票 42

如何在Spring中通过执行程序服务创建的线程中注入服务

我已经创建了一个简单的服务,比如...我必须在以后的软件包com.spring.scheduler.example.spring scheduler中从数据库中获取一些数据; import org.springframework.stereotype.Service; @ ...

回答 1 投票 0

执行程序池不处理所有项目

我需要执行一些动作5000万件物品。我在下面写了代码AtomicInteger failCounter = new AtomicInteger(0); long start = System.currentTimeMillis(); ExecutorService es = Executors ....

回答 1 投票 1

捕获当前线程的执行程序

我正在使用来自Guava的ListenableFuture,关于它们的一个好处是将Executor传递给Futures.addCallback方法,即要求在给定的线程/执行器上执行回调。在......

回答 4 投票 11

如果将一个runnable提交给具有多个线程的执行程序服务,多个线程是否会执行该runnable?

我很难理解ExecutorService在Java 8中的工作原理。我试图了解这个网站上的一些代码:https://crunchify.com/hashmap-vs-concurrenthashmap-vs -...

回答 1 投票 0

shutdownNow with executor service

我正在使用ExecutorService进行连接任务,如下所示:ExecutorService executor = Executors.newSingleThreadExecutor();未来 未来=(未来

回答 2 投票 0

Executor是否有任何场景而不是ExecutorService。 Executor界面背后的意图?

我想知道是否有任何理由使用Executor而不是ExecutorService。据我所知,JDK中没有Executor接口的实现,这也不是...

回答 1 投票 7

为什么程序不会退出?

好的,所以我试图将阻塞网络请求转换为非阻塞请求。我用于网络I / O的库确实提供了进行异步HTTP调用的功能,但无论如何,......

回答 2 投票 2

如何多线程化我的顺序Java代码

我有一个Java程序给出一个列表,在每个列表项上执行一些独立的进程(包括从一些HTTP资源检索文本并将它们插入一个独立的HashMap),...

回答 2 投票 0

在ExecutorService上调用shutdown()的原因

在过去的几个小时里,我正在阅读相当多的内容,我根本看不到任何理由(有效的理由)在ExecutorService上调用shutdown(),除非我们有一个庞大的应用程序......

回答 5 投票 66

这个Java线程锁定概念不好吗?

我将尝试简要解释一个线程锁定概念,我用一个例子提出了这个概念。请考虑以下示例程序。 public class Main {public static void main(String [] args){...

回答 4 投票 2

我是否可以访问为线程池的线程提交任务(并且正在运行)的线程?

我想在MyThreadPoolExecutor中覆盖ThreadPoolExecutor中的protected void beforeExecute(Thread t,Runnable r){},在那里我想知道哪个线程提交了这个(t)线程的任务...

回答 2 投票 1

Java 8 Executors在使用ExecutorService读取`100k` filePath时抛出RejectedExecutionException

我从ElasticSearch索引获取100k文件路径,实际文件在我的本地驱动器中可用。根据文件路径,我必须将这些文件转换为base64。拿到100k ......

回答 1 投票 0

队列已满时ThreadPoolExecutor阻塞?

我试图使用ThreadPoolExecutor执行许多任务。下面是一个假设的例子:def workQueue = new ArrayBlockingQueue (3,假)def threadPoolExecutor = new ...

回答 6 投票 49

在Java中将ExecutorService转换为守护进程

我在Java 1.6中使用ExecutoreService,只是由ExecutorService pool = Executors.newFixedThreadPool(THREADS)启动。当我的主线程完成时(以及由......处理的所有任务)

回答 7 投票 61

ExecutorService - 如何中断其中一个内部异常后从主线程调用的线程的执行

我有类SomeService。它的方法可以从不同的线程调用(例如从RestController)。该类包含ExecutorService和一些CustomClass。公共类SomeService {...

回答 1 投票 0

Thread.Pool中java.lang.Thread和线程的性能问题

Kafka消费者应用程序具有严重的延迟(在高峰时段没有足够快地消耗kafka事件)。 kafka主题有120个分区,而消费者群体共有30个主机,...

回答 2 投票 2

© www.soinside.com 2019 - 2024. All rights reserved.