executor 相关问题

用于与用于实际执行分布式作业/程序/应用程序的节点相关的问题。

安卓机房库和执行器线程异步问题。

fun setRecentToTextView() { executor.execute(Runnable { vartmp = getRecentFromDB() if(tmp.size <1){ frameLayout1.visibility = FrameLayout.VISIBLE ... ...

回答 1 投票 0

当异步方法中的一个线程发生异常时,终止所有线程。

如果在异步方法中的任何一个线程遇到异常,是否可以立即中断所有其他线程的执行?该方法返回一个completableFuture对象。...

回答 1 投票 0

ProcessPoolExecutor中的杀死进程

我正在使用Python的ProcessPoolExecutor并行运行多个进程,并在其中任何一个完成时对其进行处理。然后,我查看它们的输出,一旦其中至少有一个给出令人满意的...,

回答 1 投票 0

Spark执行程序在作业执行后未释放内存

我已经在Kubernetes上设置了一个spark集群,并创建了一个我在其中初始化spark上下文的应用程序,它是一个多线程应用程序。现在,我用4gb ram创建了四个执行程序...

回答 1 投票 0

对于在Java中运行基于cpu的简单程序的简单程序,最佳线程池大小是多少

我使用线程池执行任务,这些任务大多基于cpu并带有一点I / O,其大小比cpus的数量大一倍。 Executors.newFixedThreadPool(Runtime.getRuntime()....

回答 2 投票 13

Java并行运行方法

我有一个具有方法的Java代码,在执行期间会调用它。我希望该方法被调用并与已经执行的其余Java代码并行执行。 ...

回答 1 投票 0

Java是否需要SingleThreadPool?

我对ExecutorService有几个问题。在什么情况下,我们应该使用newSingleThreadExecutor()而不是其他方法,为什么?您能告诉我SnewSingleThreadExecutor()的真实用例吗?如果...

回答 1 投票 -1

建议:从我的服务到另一个微服务进行并行调用

我有以下要求,请根据特定条件进行数据库调用并获取结果列表。对于列表中存在的每个记录,请对微服务进行GET api调用。合并所有来自...的结果>]

回答 1 投票 0

在Hazelcast中是否可以使用自定义执行程序?

可以使用ExecutorConfig配置自定义执行程序,例如:Config config = new Config(); config.getExecutorConfig(“ my-custom-executor”)。setPoolSize(40).setName(“ my-executor”);这将...

回答 1 投票 2

Java执行器:如何设置任务优先级?

是否有可能将执行者执行的任务设置为优先级?我在JCIP中找到了一些关于它可能的声明,但是我找不到任何示例,也找不到任何相关的内容...

回答 7 投票 38

向ExecutorService对象提交任务的执行顺序是什么?

向ExecutorService对象提交任务的执行顺序是什么?场景:让我们暂时假设执行器线程池大小为5,并且我已向其提交了20个可运行任务,并且...

回答 2 投票 0

RecursiveTask线程未被join()阻塞

我有以下代码:公共类Main {公共静态void main(String [] args){ExecutorService executorService = Executors.newWorkStealingPool(1); ForkJoinPool ...

回答 1 投票 0

入站通道适配器未根据执行程序缩放

我有jdbc:inbound-channel-adapter轮询50条记录。我正在尝试通过将pollerExecutor池大小缩放到1-10来提高性能,以便多个线程可以处理50条记录:&...

回答 1 投票 0

没有代理的詹金斯动态阶段

我有一个声明性管道,在一个阶段中创建一个脚本,在该脚本中使用if / else块进行一些验证,在其中一种情况下,我声明一个具有输入的阶段(我只希望这个...

回答 1 投票 0

使用Spring Boot和执行程序的异步操作

我想了解我使用Java和Springboot的两个代码之间的区别。他们俩都相等吗?无需使用@Async并生成新线程/任务,即可提交到...

回答 1 投票 1

为什么要在exec.shutdown()之前将exec.isTerminated()与Java中的ExecutorService一起使用?

我正在研究线程,并且遇到了以下代码,并对ExecutorService exec = Executors.newFixedThreadPool(2);有所关注。 exec.execute(左); exec.exected(右);如果(!exec ....

回答 1 投票 0

Apache Spark如何收集和协调执行者的结果

发布此问题以了解Apache Spark如何收集和协调执行者的结果。假设我正在与3个执行者一起工作。我的DataFrame已分区并在这3个分区上运行...

回答 1 投票 0

你如何给一个ScheduledExecutor服务,不断推出新线程的最大时间?

采取类似下面的一个的ScheduledThreadPoolExecutor。你如何给执行者本身的时间窗口在那里可以推出新的线程。那段时间窗口之外,应立即停止开展新...

回答 1 投票 1

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

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

回答 1 投票 7

队列已满时ThreadPoolExecutor阻塞?

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

回答 6 投票 49

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