草庐IT

任务计划

全部标签

java - IntelliJ 从 Gradle 导入项目后如何运行 Gradle 任务?

我希望能够在IDEA导入我的项目后立即触发Gradle任务的执行。目前,我正在尝试解决IDEA-96615和GRADLE-2198,但我还有一些其他用例,例如可能生成一些源文件。根据IDEA的文档,我不在导入之前运行gradleidea,因为这会生成旧样式的项目,而不是基于目录的.idea一个。 最佳答案 如果我误解了您想要的内容,请告诉我,但我会试一试。(此解决方案适用于2016.2,我相信适用于15)您可以转到View->ToolWindows->Gradle然后,点击Gradle小符号,它会让你执行一个gradle任务:希望这

java - 确保所有任务完成的同步对象

我应该使用哪个Java同步对象来确保完成任意数量的任务?约束是:每项任务都需要很长时间才能完成,适合并行执行任务。有太多任务无法放入内存(即我无法将每个任务的Future放入Collection中,然后调用get在所有future上)。我不知道会有多少任务(即我不能使用CountDownLatch)。ExecutorService可能是共享的,所以我不能使用awaitTermination(long,TimeUnit)例如,对于GrandCentralDispatch,我可能会这样做:letworkQueue=dispatch_get_global_queue(QOS_CLASS_BA

apache-kafka - Kafka-connect sink任务忽略文件偏移存储属性

我在使用ConfluentJDBC连接器时遇到了非常奇怪的行为。我很确定它与Confluent堆栈无关,而是与Kafka-connect框架本身有关。因此,我将offset.storage.file.filename属性定义为默认/tmp/connect.offsets并运行我的接收器连接器。显然,我希望连接器在给定文件中保留偏移量(它在文件系统中不存在,但应该自动创建,对吧?)。文档说:offset.storage.file.filenameThefiletostoreconnectoroffsetsin.Bystoringoffsetsondisk,astandaloneproce

java - 按顺序执行任务但从池中获取线程的 ExecutorService

我正在尝试构建ExecutorService的实现,我们称它为SequentialPooledExecutor,具有以下属性。SequentialPooledExecutor的所有实例共享同一个线程池对同一SequentialPooledExecutor实例的调用按顺序执行。换句话说,实例在开始处理其队列中的下一个任务之前等待当前正在执行的任务的终止。我目前正在自己​​实现SequentialPooledExecutor,但我想知道我是否在重新发明轮子。我查看了ExecutorService的不同实现,例如Executors类提供的实现,但没有找到满足我要求的实现。您是否知道我是否缺少

B站画质补完计划:视频超分让像素细腻生动

1前言为了给用户提供更清晰的画质体验,B站自研的超分辨率算法已经在站内广泛应用,支持了如《赛马娘》、《流浪地球2》、《权力的游戏》、英雄联盟S赛赛事直播等知名番剧、电影电视剧以及重要游戏赛事直播的4K视频流生产。2超分算法的应用背景2.1不同分辨率视频的画质差异随着终端显示技术的快速发展,4K规格的终端显示设备已经逐渐开始普及,用户对于4K清晰度视频的观看需求也呈现出不断增长的趋势。然而,由于制作年代久远、拍摄设备受限等原因,流媒体平台上大量视频片源还是以1080P、720P的规格存在,无法满足用户在高规格显示设备上观看4K清晰度视频的需求。那么,1080P视频和4K视频的画面质量差距有多大呢

java - Java Stream API 是如何选择执行计划的?

我刚开始学习Java8中的StreamAPI和一般的函数式编程,但对Java并不陌生。我有兴趣了解和了解StreamAPI如何选择执行计划。它如何知道哪些部分需要并行化,哪些部分不需要?存在多少种执行计划?基本上,我想知道为什么Java8中的Streams有助于使事情变得更快,以及它如何发挥这种“魔力”。我找不到太多关于这一切如何运作的文献。 最佳答案 这个问题有点宽泛,不好详细解释,但我会尽力回答到满意的程度。我还使用了ArrayList的Stream示例。当我们创建流时,返回的对象称为ReferencePipeline.这个对象

Java 计划执行器准确性

我在使用Java计划执行程序时遇到了一个特殊情况,想知道我遇到的情况是否正常。我需要安排以5秒的预定义速率执行的任务。预计这些任务的执行时间有时会超过5秒,但是当运行它们的时间低于5秒时,备份的任务列表应该快速连续运行以catch进度。运行任务时,了解最初计划的执行时间很重要(想想java.util.TimerTask中的scheduledExecutionTime())。最后,我需要跟踪计划时间和实际时间之间的差异,以确定日程何时“偏离”以及偏离了多少。到目前为止,我已经通过使用Java执行器实现了所有这些,下面的类说明了总体思路:publicclassExecutorTest{pu

java - 使用 ant 停止并行 java 任务

我正在开发两个Java程序,它们在具有典型服务器/客户端关系的单独VM中运行。使用ant的并行/顺序任务,我已经能够让ant运行服务器,然后运行客户端。我现在想要这样,当客户端进程停止时,Ant会杀死服务器。我已经看到这是通过针对特定服务器应用程序(如TomCat)的自定义ant任务完成的,是否存在任何方法可以通过通用java进程执行此操作? 最佳答案 由于您正在开发服务器应用程序,因此可以让它监听“关闭”命令。然后你可以让ant在客户端退出时向它发送关闭命令,比如:另一个可能对您有用的选项是在daemons元素内启动服务器。这将使

java - 在 Java 中获取 Spark 中的当前任务 ID

我需要在Spark中获取当前任务的ID。我一直在谷歌和官方API中搜索,但我能找到的唯一ID是执行者ID和RDD的ID。有谁知道如何获得任务的唯一ID?我已经看到类TaskInfo正是我要找的东西,但我不知道如何获取此类的实例。 最佳答案 为了获得特定的任务ID,您可以使用TaskContext:importorg.apache.spark.TaskContext;textFile.map(x->{TaskContexttc=TaskContext.get();System.out.println(tc.taskAttemptId(

java - 如何让 gradle 的构建任务生成 shadow jar 而不是 "regular"jar?

(这是使用gradle2.4)对于我的一个项目,分为几个子模块,我使用shadowplugin这非常适合我的需要;它有一个主要的,并且按照插件的自述文件的建议,我将应用程序插件与它结合使用,以便在list中生成Main-Class,一切正常。现在,这是一个SonarQube插件项目,我也使用(成功!)gradlesonarpackaginplugin.这个插件的作用是,当您./gradlewbuild时,生成声纳插件而不是“常规”jar。我希望在这里为我的子项目做同样的事情,除了我希望它只生成影子jar插件而不是“常规”插件......现在我使用这个简单的文件生成这两个插件:build