草庐IT

cron-task

全部标签

java Callable FutureTask Excecuter : How to listen to finished task

我对执行者服务还很陌生。喜欢自己做所有事情,但我认为是时候相信这些服务了。我想通过Executer传递一个Runnable。执行者将其包装在FutureTask中并将其交还给我。现在我调用polldone()方法。但我希望在done()方法返回true时得到通知。有一个get()方法会阻塞直到Runnable完成,但是之后我需要为每个作业添加一个额外的线程,只是为了查看它何时完成.我可以给我的执行者一些额外的Callable以获得任务完成的通知吗?到这里怎么走?我可以在run方法的末尾添加一些代码,但是done()可能仍然是false... 最佳答案

java - Ant 中的 "Failed to create task or type antlib:org.apache.maven.artifact.ant:mvn"错误

在build.xml中运行Ant任务时,Ant构建无法运行。我在控制台中收到以下错误:Buildfile:F:\EclipseProjects\my_project\build.xml[typedef]Couldnotloaddefinitionsfromresourceorg/apache/maven/artifact/ant/antlib.xml.Itcouldnotbefound.BUILDFAILEDF:\my_project\build.xml:32:Problem:failedtocreatetaskortypeantlib:org.apache.maven.artifac

java - 是否有用于创建 Cron 表达式的 Java 代码?

关闭。这个问题需要更多focused.它目前不接受答案。想改进这个问题吗?更新问题,使其只关注一个问题editingthispost.关闭4年前。Improvethisquestion我需要一个Java代码来创建基于用户输入的cron表达式。用户输入是时间、频率和执行次数。

java - 了解 Stream API ForEach Task 中的主循环

似乎JavaStreams并行化的核心是ForEachTask。理解其逻辑似乎对于获得必要的心智模型至关重要,该心智模型可以预测针对StreamsAPI编写的客户端代码的并发行为。然而,我发现我的预期与实际行为相矛盾。作为引用,这里是关键的compute()方法(java/util/streams/ForEachOps.java:253):publicvoidcompute(){SpliteratorrightSplit=spliterator,leftSplit;longsizeEstimate=rightSplit.estimateSize(),sizeThreshold;if((

java - "VM Periodic Task Thread"是什么?

我可以在我的线程转储中看到这个线程:"VMPeriodicTaskThread"prio=10tid=0x00007fc23000e800nid=0x49e6waitingoncondition这是什么? 最佳答案 查看最新的OpenJDK源代码,这是C++级别的线程,它在没有native定时器中断的系统上执行许多任务。它似乎主要用于采样/分析JVM正在做什么。 关于java-"VMPeriodicTaskThread"是什么?,我们在StackOverflow上找到一个类似的问题:

java - play framework 2.0 中的 Cron Job

很难说出这里要问什么。这个问题模棱两可、含糊不清、不完整、过于宽泛或夸夸其谈,无法以目前的形式得到合理的回答。如需帮助澄清此问题以便重新打开,visitthehelpcenter.关闭10年前。PlayFramework2.0如何通过cron表达式来调度任务?相当于Play1的@On("")注释

Java 并发数 : executing many "infinite" tasks with few threads

我正在为一组根据牛顿定律在空间中移动的N个粒子构建一个(并发)模拟器。我的想法是将每个粒子建模为一个任务,它与其他粒子(任务)相互作用以获得它们的位置和质量,从而计算它所受到的合力。每个粒子任务都是while(true){force=thisParticle.calculateNetForce(allTheParticles);thisParticle.waitForAllTheParticlesToCalculateNetForce();//synchronizationthisParticle.updatePosition(force);thisParticle.waitForAl

java - 线程池执行器 : Tasks are getting queued up and not submitted

我们有一个场景,提交给ThreadPoolExecutor的任务是长时间运行的。当线程池启动时,我们以核心池大小=5、最大池大小=20和队列大小10启动它。在我们的应用程序中,大约有10个任务被提交。大多数情况下,这些任务运行几分钟/小时,然后完成。然而,有一种情况是所有5个任务都在I/O上挂起。结果我的核心池大小达到了最大值,但我的Threadpoolexecutor队列未满。所以额外的5个任务从来没有机会运行。请建议我们如何处理这种情况?在这种情况下,队列越小越好吗?初始化threadPool时最佳队列大小是多少?还有关于挂起的任务,有没有什么办法可以把线程从线程池中拉出来?在那种

深入理解flink的task slot相关概念

【背景】之前对flink的taskslot的理解太浅了,重新捋一下相关知识点为什么需要TaskSlot我们知道,flink中每个TaskManager都是一个 JVM 进程,可以在单独的线程中执行一个或多个 subtask(线程)。但是TaskManager 的计算资源是有限的,并不是所有任务都可以放在同一个 TaskManager 上并行执行。并行的任务越多,每个线程的资源就会越少。为了控制并发量,即限制一个 TaskManager 能同时接受多少个 task,我们需要在 TaskManager 上对每个任务运行所占用的资源做出明确的划分,这就是所谓的taskslot(任务槽)。TaskSl

我们一起聊聊 .NET 全能 Cron 表达式解析库

前言今天大姚给大家分享一个.NET全能Cron表达式解析类库,支持Cron所有特性:TimeCrontab。Cron表达式介绍Cron表达式是一种用于配置定时任务的时间表达式。它由一系列字段组成,每个字段代表任务在不同时间维度的调度规则。Cron表达式常用于各种系统中,如操作系统的定时任务、应用程序的定时调度、数据备份等。Cron在线表达式生成器:https://cron.ciding.cc/图片项目特点支持Cron所有特性超高性能易拓展很小,仅4KB无第三方依赖开源、跨平台高质量代码和良好单元测试支持.NETFramework3.5+及后续版本项目源代码图片项目安装创建一个名为TimeCro