草庐IT

unique_future

全部标签

java - 您可以将 Future/Futuretask 对象与 Spring TaskExecutors 一起使用吗?

是否可以使用JavaFutureTask使用SpringTaskExecutor获得Future目的?我正在寻找实现JavaExecutorService的TaskExecutor接口(interface),特别是submit()方法。翻看SpringJavadocs不会透露任何这样的类(class)。是否有一些我不知道的通过SpringTaskExecutors处理future的替代方法?如果可能的话,您能否也提供一个示例? 最佳答案 Spring3已将支持Future对象的提交方法添加到AsyncTaskExecutor.在那之

java - Callable和Future的实际实现

我正在理解细粒度util.concurrency。JVM中JavaCallable和Future的实现在哪里?我找到了Futureclass它在Java语言的高层描述future的地方,我试图找到它在较低层描述的地方。总而言之,找到Future和Callable的实际实现会很有趣,例如:处理Future.get()或Callable.call()并规定它们应该如何工作的JVM部分。期待您的回复,阿空卡格瓦 最佳答案 WhereisimplementationoftheJavaCallableandFuturelocatedinthe

java - Future.get() 是 Thread.join() 的替代品吗?

我想编写一个永远运行的命令行守护进程。我知道如果我希望JVM能够在linux中正常关闭,则需要通过一些C代码包装Bootstrap。我想我现在可以使用关闭Hook。关于我的问题:我的main(String[])block将启动一个单独的Superdaemon。Superdaemon将永远轮询和循环。所以通常我会这样做:classSuperdaemonextendsThread{...}classBootstrap{publicstaticvoidmain(String[]args){Threadt=newSuperdaemon();t.start();t.join();}}现在我想如果

Java 8 CompletableFuture 与 Netty Future

JDK8中引入的CompletableFuture与Netty提供的io.netty.util.concurrent.Future相比如何?Netty文档提到了这一点JDK8addsCompletableFuturewhichsomewhatoverlapsio.netty.util.concurrent.Futurehttp://netty.io/wiki/using-as-a-generic-library.html我试图获得答案的问题是:他们的相同点和不同点是什么?两者的性能特征有何不同?哪一个能够更好地扩展?关于相同点/不同点,我已经能够提出以下几点:相似点:与JavaFutu

java - Scala 和 Java 的 future 显然有意想不到的互动

我们在ScalaPlayFramework应用程序中使用Elasticsearch0.90.7,其中“doSearch”方法的结尾如下所示:defdoSearch(...)={...valactionRequessBuilder:ActionRequestBuilder//constructedearlierinthemethodvalexecutedFuture:ListenableActionFuture=actionRequestBuilder.executereturnexecutedFuture.actionGet}其中ListenableActionFutureextend

java - 添加/扩展由 ListeningExecutorService 创建的 Future 的行为

最终目标是为ListenableFuture添加额外的行为s基于Callable/Runnable参数的类型。我想为每个Future添加额外的行为方法。(示例用例可以在AbstractExecutorService'sjavadoc和Goetz的JavaConcurrencyinPractice的第7.1.7节中找到)我有一个现有的ExecutorService覆盖newTaskFor.它测试参数的类型并创建FutureTask的子类。这自然支持提交以及invokeAny和invokeAll.如何为ListenableFuture获得相同的效果由ListeningExecutorSer

java - 等待多个 future 的回调

最近我深入研究了一些使用API的工作。API使用Uniresthttp库来简化从网络接收的工作。当然,由于数据是从API服务器调用的,因此我尝试通过对API的异步调用来提高效率。我的想法结构如下:通过返回future结果创建数据数组显示数据+从数据中收集的附加信息因此,在开始第二步之前,我需要返回所有数据。我的代码如下:Future>future1=Unirest.get("https://example.com/api").asJsonAsync(newCallback(){publicvoidfailed(UnirestExceptione){System.out.println(

java - XML 或 XUL 是 Java GUI 构建的 future 吗?

在用Swing编程花费大量时间和代码之后,我认为这不可能是最先进的JavaGUI构建。在没有为eclipse找到用户友好的可视化图形用户界面之后,我偶然发现了使用XMLUI工具包构建的声明式GUI......我想:一定是这样!我认为这是正确的方法,既简单又接近网络编程。但是在网上和SO上看了一圈之后,我的印象是它不是很常见!尽管有很多实现和API,但似乎其中大多数都已经过时,并且在过去5年中没有更新。所以我想知道:我的感觉是否正确,XML在JavaGUI中不是很普遍?如果是这样-原因是什么?也许它无法被接受,或者它有一些主要缺点,或者人们在网络上做所有事情而不是使用fatclients

java - 如何将 java Future<V> 转换为 guava ListenableFuture<V>

我需要找到一种方法将Future转换为ListenableFuture。目前我正在使用返回Future的服务,但我需要连接一个监听器。我无法更改服务界面,因为它不属于我。有没有一种简单的方法可以做到这一点?我已经阅读了guava文档,但我仍然找不到实现它的方法。 最佳答案 Guava为这种转换提供了JdkFutureAdapters类型。API州UtilitiesnecessaryforworkingwithlibrariesthatsupplyplainFutureinstances.例如Futurefuture=...;List

java - Java 中带有 invokeAll() 和 Future 的 ExecutorService

手头有以下代码:ExecutorServiceexecutor=Executors.newFixedThreadPool(10);Collectioncollection=newArrayList();for(intn=1;n>futures=executor.invokeAll(collection);for(Futurefuture:futures){future.get();if(future.isDone()){System.out.println("true");}elseSystem.out.println("false");}}catch(Exceptione){e.pr