草庐IT

任务队列

全部标签

java - 调用包含 hbm2ddl 任务的 ant 脚本时,Runtime.exec 会卡住吗?

为了启动一个ant脚本,我使用java.lang.Runtime类的exec方法,如下所示:Processprocess=Runtime.getRuntime().Exec(JAVA_HOMEANT_HOME-jar/lib/ant-launcher.jar-BuildFilefile.xml);这个方法,尽管看起来很简单,但是它带来了几个问题,在javadoc中描述如下:BecauseSomenativeplatformsProvideonlylimitedbuffersizeforstandardinputandoutputstreams,failuretopromptlywrit

java - 当队列持久时,HornetQ Producer 变慢

我已经尝试在horntQ中使用PersistentQueue。我做了两个单独的例子(生产者,消费者)。我的消费者运行良好,但生产者花费太多时间来完成发送消息。我分别跑过和一起跑过。可能是什么问题呢?我的代码是:publicclassHornetProducerimplementsRunnable{Contextic=null;ConnectionFactorycf=null;Connectionconnection=null;Queuequeue=null;Sessionsession=null;MessageProducerpublisher=null;TextMessagemess

java - Java 中 HashMap 对象的优先级队列

我创建了一个HashMap对象,它存储一个String作为键,相应的值作为int。现在我想要一个优先级队列,它具有HashMap对象中存在的所有字符串,其值作为分配优先级的引用。我写了下面的代码publicclassURIQueue{privateHashMapCopyQURI;privatePriorityQueueQURI;publicclassTComparator{publicintcompareTo(Strings1,Strings2){if(CopyQURI.get(s2)-CopyQURI.get(s1)>=0){return1;}else{return0;}}}publ

java - JMS 队列上多线程消息处理的最佳实践

我目前正在将JMS支持添加到类似应用程序服务器的框架中。JMS将由HornetQ(独立代理,服务器类路径上的hornetqjar)实现,但既没有JBoss,也没有spring,也没有其他任何可以提供MDB的东西。下一步是将消息监听器添加到xa队列,以允许并行处理传入消息。有些消息会启动长时间运行的任务,因此基本思想是从onMessage方法生成工作线程。在漫长的互联网旅程中,我遇到了thisdiscussion,其中一位参与者提到,他不会这样做,而是使用一个额外的内部队列来完成任务:然后(单线程)消息监听器将简单地从入站队列中获取消息并为内部队列创建新消息,其中在该内部队列的另一端,一

java - 更改 ThreadPoolExecutor 的队列大小

我需要能够更改ThreadPoolExecutor任务队列的大小.当然,BlockingQueue不支持改变大小,ThreadPoolExecutor也不支持改变队列。所以,我想出的方法是使用ThreadPoolExecutor.shutdownNow(),这会返回一个尚未执行的Runnable列表。然后我可以创建一个具有所需队列大小的新执行程序并重新提交所有任务。问题在于调用shutdownNow()时正在进行的任务。据我从javadoc中得知,执行程序将在当前执行任务的所有线程上调用Thread.interrupt()。我不希望我的任务被杀死。这个问题可能是询问如何编写我的任务以使

java - 如何以编程方式报告 AWT/Swing 事件队列长度?

理想情况下,答案将与平台无关,但特定于平台(尤其是OracleJVM)也很有用。我正在处理的项目仍在运行版本6JVM。特殊需求与不时“卡住”的GUI有关。我很清楚在EDT上进行GUI工作。该程序在Windows上运行良好,但在转移到Linux后,这些“奇怪”的GUI问题开始发生。实际上,这个问题已经发生在两个应用程序上,都是在从Windows迁移到Linux之后。JVisualVM显示超过1000万个java.awt.EventQueueItem对象。怀疑是AWT队列的增长速度超过了它在Linux上的服务速度,因此我们的想法是在应用程序上放置一个AWT队列长度指示器,并查看它在队列增长

java - 可以按优先级指定 Eclipse 任务标签颜色吗?

这是专门针对EclipseIDE的。我知道可以通过以下方式编辑任务标签的颜色(和字体等):Preferences->Java->Editor->SyntaxColoring->Comments->TaskTags但我想做的是为不同的任务标签优先级定义不同的颜色。例如,TODO是Normal优先级,所以应该是蓝色;而FIXME是高优先级,所以应该是红色的。这可能吗?如果是,怎么办?编辑:这是在Java编辑器本身中进行的。 最佳答案 目前还不可能-配置(在General→Editors→TextEditors→Annotations下)

java - 如何依赖 Gradle 中的所有 *compile 和 *testCompile 任务

我想在animalSniffer插件第一个任务依赖于所有sourceSets中所有生产类(Java、Groovy、Scala)的编译,第二个任务依赖于所有sourceSets中所有测试类的编译(可能分开test和集成测试).我不想依赖于*classes任务,因为*classes任务应该依赖于animalSniffer任务(检测Java版本API不兼容编译后可以停止构建)。在Gradle中有没有比检查AbstractCompile任务名称的实例是否以“compileTest”开头更好的方法来实现这一点? 最佳答案 您可以使用tasks

java - executorService.scheduleAtFixedRate 永远运行任务

我希望任务在1分钟的间隔后永远运行。为了完成我在中写下的任务publicvoidpoll(){ScheduledExecutorServiceexecutorService=Executors.newScheduledThreadPool(1);ScheduledFuturefiles=executorService.scheduleAtFixedRate(newRunnable(){@Overridepublicvoidrun(){Stringpath="/Desktop/PNL/Test";ListfilesPaths=newArrayList();Filefolder=newFi

java - Apache Storm Bolt 任务在一段时间后未收到消息

我们有一个Storm拓扑,其中配置了一个spout和两个bolts。Spout不断地从数据库中查询数据并将元组发送到第一个bolt进行一些处理。第一个bolt进行一些处理并将元组发送到第二个bolt,第二个bolt调用第三方网络服务并发送数据。所以,一段时间后发生了什么,最后一个bolt没有得到任何元组,如果我们重新启动拓扑它工作正常。这里只有最后一个bolt有问题。其他spout和firstbolt运行良好,我没有使用acking框架。在这种情况下,我只配置了一个worker`。TopologyBuilderbuilder=newTopologyBuilder();builder.s