- mongodb - 在 MongoDB mapreduce 中,如何展平值对象?
- javascript - 对象传播与 Object.assign
- html - 输入类型 ="submit"Vs 按钮标签它们可以互换吗?
- sql - 使用 MongoDB 而不是 MS SQL Server 的优缺点
我可能会想象一些计划执行的任务需要很长时间,而 ScheduledThreadPoolExecutor
会为其他需要运行的任务创建额外的线程,直到达到最大线程数。
但是好像我只能为池指定固定数量的线程,为什么会这样呢?
最佳答案
为什么,我也不知道。但我可以想象。
计算机的资源量是有限的。也不是所有资源都可以同时处理。
如果多个进程同时加载文件,它们的加载速度将比按顺序加载时要慢(至少在硬盘上)。
处理器对同时处理多个线程的支持也有限。在某些时候,操作系统或 JVM 切换线程所花费的时间比线程执行其代码所花费的时间要多。
这是 ScheduledThreadPoolExecutor
被设计成这样的一个很好的理由。您可以将任意数量的作业放入队列中,但同时执行的作业永远不会超过可以高效运行的作业。当然,这取决于你自己来平衡。
如果您的任务受 IO 限制,我会将池大小设置为小,如果它们受 CPU 限制,则设置大一点(32 左右)。您还可以制作多个 ScheduledThreadPoolExecutor
,一个用于 IO 绑定(bind)任务,一个用于 CPU 绑定(bind)任务。
关于java - 为什么 ScheduledThreadPoolExecutor 只接受固定数量的线程?,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/3353002/
ScheduledThreadPoolExecutor 扩展自 一文秒懂 Java 线程池之 ThreadPoolExecutor 讲解的 了ThreadPoolExecutor 类,并且添加了其它方
ThreadPoolExecutor 和 ScheduledThreadPoolExecutor 是线程安全的吗?现在,我有一个场景如下: 5 ThreadPoolExecutor(s) exec1(
我有以下类(class) public class MaintanceTools { public static final ScheduledThreadPoolExecutor THREA
我需要更改 ScheduledThreadPoolExecutor 的运行任务的执行时间。 我有类似的东西 executor.schedule(new Runnable() {blablal},10,
我想要一些线程池,它每隔固定的时间运行一些任务(这个线程池一直在获取任务)。每个任务都会调用一些 API 来获取一些值,该值可以为 null。我希望仅当返回值为空时任务才再次运行(在固定时间后)。否则
已关闭。此问题不符合Stack Overflow guidelines 。目前不接受答案。 有关您编写的代码问题的问题必须在问题本身中描述具体问题 - 并包含有效代码以重现该问题。请参阅SSCCE.o
我有一个具有固定延迟的任务,并且希望在 ScheduledThreadPoolExecutor 队列中只有一个任务。我的想法是使用 getQueue().isEmpty() 来检查队列中是否只有一个任
我如何将参数传递给 ScheduledThreadPoolExecutor? 我有以下代码。您会注意到,我声明了一个变量“num”,并将其作为参数传递给 exampleFunction()。 exam
假设我有这样的方法 public void scheduleCleanup(String parameter) { final SomeObject someObject = new Some
我知道由于各种原因我必须使用它而不是 java.util.Timer。所以,为了研究这个,我正在查看文档,我有几个问题: scheduleWithFixedDelay() 是如何工作的? 我的理解是:
例程 myProcessToRun() 需要执行 100 次,但每次执行之间需要大约一秒钟的延迟。 以下 FOR 循环与 ScheduledThreadPoolExecutor 对象结合使用。 for
ScheduledThreadPoolExecutor 中有两个属性具有以下 getter(以及随附的 setter) : boolean getContinueExistingPeriodicTas
这个问题只是为了对这些概念有一些想法,以了解业内人士将其用于什么目的。 如果您可以仅给出一些示例用法,我将不胜感激。我知道它们是如何工作的,并确实阅读了有关它们的google文档,但我似乎仍然很难选择
所有可用的 ScheduledThreadPoolExecutor 构造函数都需要一个 corePoolsize 参数。但我不确定我实际需要多少? 我计划在一个类中使用它,其中一个实例仅使用 1 个计
我正在尝试在 scala play 框架中实现预定作业。 以下是我的代码: def subCron = { val task = new Runnable { def run() = {
ScheduledThreadPoolExecutor 的文档说 -安排在完全相同执行时间的任务以先进先出 (FIFO) 的提交顺序启用。 这是否意味着应该同时完成的任务永远不会同时完成。相反,它们以
我有这个简单的代码片段: /** * @param args the command line arguments */ public static void main(String[] args
我写了下面的代码: import java.util.Calendar; import java.util.concurrent.ScheduledThreadPoolExecutor; import
如果我使用ThreadPoolExecutor,我有多种构造函数,我可以为池的工作队列传递/使用我自己的队列。 现在我看到 ScheduledThreadPoolExecutor 是 ThreadPo
我正在阅读 ScheduledThreadPoolExecutor JavaDoc并遇到了以下事情: Delayed tasks execute no sooner than they are ena
我是一名优秀的程序员,十分优秀!