草庐IT

asynchronous-iteration-patterns

全部标签

java - 如何从 Iterable/Collection 创建 TreeMultimap?

我正在尝试修剪TreeMultimap,并返回相同结构的TreeMultimap(但已修剪)。例如,我有不同的新闻提供者返回无序新闻。我需要按日期对新闻进行排序,并在按最近日期排序的多图中维护这种排序。然后我需要能够返回最新的X新闻。每个日期,可能有很多新闻。TreeMultimaplatestNews=TreeMultimap.create(Ordering.natural().reverse(),Ordering.natural());因为TreeMultimap没有修剪或大小,我设法返回一个Iterable并用它限制结果,但是如何创建一个新的TreeMultimap来自Itera

java - 我在哪里可以配置 Java EE 6 中@Asynchronous 调用背后的线程池?

我最近了解到我可以轻松制作anysessionbeanmethodAsynchronous通过简单地添加@Asynchronous注释。例如@AsynchronouspublicFutureprocessPayment(Orderorder)throwsPaymentException{...}我知道JavaEE7添加了ConcurrencyUtilities,但是在JavaEE6中,@Asyncronous方法的线程池配置在哪里?有没有办法设置超时?它是一个固定的线程池吗?一个缓存的?它的优先级是什么?它可以在容器中的某处配置吗? 最佳答案

java - 采访 : Design an iterator for a collection of collections

为java中的集合设计一个迭代器。迭代器应该隐藏嵌套,允许您迭代属于所有集合的所有元素,就好像您在处理单个集合一样 最佳答案 这是一个老问题,但如今(2019年)我们有了JDK8+好东西。特别是,我们有流,这使得这个任务变得简单:publicstaticIteratorflatIterator(Collection>collections){returncollections.stream().filter(Objects::nonNull).flatMap(Collection::stream).iterator();}我正在过滤

java - 公开内部集合项时应该使用 Iterator 还是 Iterable?

我有一个带有私有(private)可变数据列表的类。我需要在以下条件下公开列表项:列表不应在外部修改;使用getter函数的开发人员应该清楚,他们获得的列表无法修改。应将哪个getter函数标记为推荐方法?或者你能提供更好的解决方案吗?classDataProcessor{privatefinalArrayListsimpleData=newArrayList();privatefinalCopyOnWriteArrayListcopyData=newCopyOnWriteArrayList();publicvoidmodifyData(){...}publicIterablegetU

java - 如何用 Streams 替换 Iterables.filter()?

我正在尝试从Guava迁移到Java8Streams,但不知道如何处理可迭代对象。这是我的代码,用于从可迭代对象中删除空字符串:Iterablelist=Iterables.filter(raw,//it'sIterablenewPredicate(){@Overridepublicbooleanapply(Stringtext){return!text.isEmpty();}});注意,这是一个Iterable,不是Collection.它可能包含无限数量的项目,我无法将它们全部加载到内存中。我的Java8替代品是什么?顺便说一句,有了Lamba,这段代码看起来会更短:Iterabl

java - RxJava Observable "Iteration"是如何工作的?

我开始尝试使用RxJava和ReactFX,并且对它们非常着迷。但在我进行实验时,我有很多问题,而且我一直在寻找答案。我观察到的一件事(没有双关语意)当然是惰性执行。通过下面的探索性代码,我注意到在调用merge.subscribe(pet->System.out.println(pet))之前没有执行任何操作。但令我着迷的是,当我订阅第二个订阅者merge.subscribe(pet->System.out.println("Feed"+pet))时,它再次触发了“迭代”。我想了解的是迭代的行为。它的行为似乎不像只能使用一次的Java8stream。它真的是一次遍历每个String并

java - 为什么 NodeList 不扩展 Collection 或 Iterable?

也许这不完全是一个编程问题。但是……为什么是org.w3c.dom.NodeList不是java.lang.Iterable的扩展名界面?这对我来说听起来很反直觉。特别是因为文档说:TheNodeListinterfaceprovidestheabstractionofanorderedcollectionofnodes,withoutdefiningorconstraininghowthiscollectionisimplemented.NodeListobjectsintheDOMarelive.TheitemsintheNodeListareaccessibleviaaninte

java - List Iterator的add()方法对迭代器做了什么?

我希望能够向ArrayList中插入元素使用ListIterator,但不知何故,即使在阅读了与ListIterator的添加方法相关的文档后,我仍然感到困惑类,如果我做这样的事情for(inti=0;i这段代码片段对我的列表迭代器做了什么,它把列表迭代器移到了哪里?当我运行以下代码时,我得到的结果是“Hi”-:importjava.util.ArrayList;importjava.util.ListIterator;publicclassListIter{publicstaticvoidmain(String[]args){String[]s={"Hi","I","am","Ank

Java 8 流 : iterate over Map of Lists

我有以下对象和map:MyObjectStringname;Longpriority;foobar;Map>anotherHashMap;我想在另一个map中转换map。结果映射的键是输入映射的键。结果映射的值是我的对象的属性“名称”,按优先级排序。排序和提取名称不是问题,但我无法将其放入结果映射中。我用旧的Java7方式来做,但如果可以使用流式API就好了。Map>result=newHashMap();for(Stringidentifier:anotherHashMap.keySet()){ListgeneratedList=anotherHashMap.get(identifi

java - 包含 Iterable 和 Iterator 的方法?

是否有一种简单的方法来检查元素是否包含在可迭代对象或迭代器中,类似于Collection.contains(Objecto)方法?即而不是必须写:Iterabledata=getData();for(finalStringname:data){if(name.equals(myName)){returntrue;}}我想写:Iterabledata=getData();if(Collections.contains(data,myName)){returntrue;}我真的很惊讶没有这样的东西。 最佳答案 在Java8中,您可以将I