草庐IT

ZMQ_STREAM

全部标签

java - 为什么没有提供 Stream<E> 的接口(interface)?

为了防止实现细节泄露,而不是返回,例如Collection,一个人可能会实现Iterable,然后需要实现Iterator来自Iterable界面。因此,无论内部数据结构如何管理,对元素的访问都是通过Iterator进行的。.对于Java8,人们可能希望添加Streamstream()至MyCoolObject.(另请参阅:Java8Lambdas一书中关于支持stream的建议)。虽然添加方法并不困难(而且我确实阅读了关于WhyIterableDoesn'tProvideStream的问题),但Java没有为Streamable添加接口(interface)似乎很奇怪。镜像Itera

java - java.util.stream.Streamable 发生了什么?

早jdk8-eajavadocslikethis表示有一个java.util.stream.Streamable接口(interface),这似乎与Stream具有相同的关系作为Iterable有一个Iterator.现在我们似乎陷入了Supplier的困境,这当然不一样。Streamable发生了什么? 最佳答案 它已经被删除了一段时间。Therationale删除由BrianGoetz给出:CurrentlytheonlyimplementorisCollection,andalloftheotherstream-bearing

Java NIO : transferFrom until end of stream

我正在研究NIO库。我正在尝试监听端口8888上的连接,一旦连接被接受,就将该channel中的所有内容转储到somefile。我知道如何使用ByteBuffers来做到这一点,但我想让它与据称super高效的FileChannel.transferFrom一起工作.这是我得到的:ServerSocketChannelssChannel=ServerSocketChannel.open();ssChannel.socket().bind(newInetSocketAddress(8888));SocketChannelsChannel=ssChannel.accept();FileCh

java - 是否有可能在 Stream 中获取下一个元素?

我正在尝试将for循环转换为功能代码。我需要向前看一个值,也需要向后看一个值。是否可以使用流?下面的代码是将罗马文本转换为数值。不确定具有两个/三个参数的reduce方法是否可以提供帮助。intpreviousCharValue=0;inttotal=0;for(inti=0;i0){total+=(romanNum.getNumericValue()-previousCharValue);previousCharValue=0;}else{if(i 最佳答案 不,使用流是不可能的,至少不容易。流API从处理元素的顺序中抽象出来:流

java - 如何解决 JXL 错误 : jxl. read.biff.BiffException: Unable to recognize OLE stream

我正在尝试从我的.csv文件中获取单元格数据,但出现错误:jxl.read.biff.BiffException:无法识别OLE流我不知道怎么解决,请给我一些解决方案此代码适用于jxlapi并且该api是否支持.csv?引用代码:publicvoidread()throwsIOException,BiffException{FileinputWorkbook=newFile(inputFile);try{w=Workbook.getWorkbook(inputWorkbook.getAbsoluteFile());//GetthefirstsheetSheetsheet=w.getSh

java - 什么更有效率 : sorted stream or sorting a list?

假设我们在一个集合中有一些项目,我们想使用某个比较器对它们进行排序,期望结果在一个列表中:Collectionitems=...;ComparatoritemComparator=...;其中一种方法是对列表中的项目进行排序,例如:ListsortedItems=newArrayList(items);Collections.sort(sortedItems,itemComparator);另一种方法是使用排序流:ListsortedItems=items.stream().sorted(itemComparator).collect(Collectors.toList());我想知道

java - Java Stream 并行化可视化

通常并不清楚并行流是如何将输入分割成block的,以及block的连接顺序。有什么方法可以可视化任何流源的整个过程,以更好地了解发生了什么?假设我创建了一个这样的流:Streamstream=IntStream.range(0,100).boxed().parallel();我想看到一些树状结构:[0..99]_____/\_____||[0..49][50..99]__/\____/\__||||[0..24][25..49][50..74][75..99]这意味着整个输入范围[0..99]被拆分为[0..49]和[50..99]范围又进一步split。当然,这样的图应该反射(ref

java - 哪个 .jar 文件有 javax.xml.stream.*?

我在运行Java1.5的Mac上再次遇到问题...。我在哪里可以获得具有javax.xml.stream.XMLInputFactory的.jar文件?我想使用StAX,但不知道如何正确设置。我似乎无法获得此设置。我现在已经下载了jaxp-api.jar、jsr173_1.0_api.jar、sjsxp.jar、stax-api-1.0.1.jar、stax2-api-3.0.1.jar和woodstox-core-asl-4.0。5.jar;将它们全部放入我的java/lib/ext目录,确保它们在我的eclipse构建路径上,删除Maccom.apple.quarantine扩展属

java - 使用 Java Stream API 将 Map<K, Map<V, X>> 中的类型 X 转换为 Y

我想从map的map转换内部map。旧map:Map>整数表示秒新map:Map>我尝试创建新的内部map,但出现错误Error:java:nosuitablemethodfoundforputAll(java.util.stream.Stream)methodjava.util.Map.putAll(java.util.Map)isnotapplicableoldMap.entrySet().stream().collect(Collectors.toMap(Map.Entry::getKey,e->newHashMap(){{putAll(e.getValue().entrySet

java - Collection.stream() 的实现

我已经在J​​DK1.8上工作了几天,我遇到了一些与此类似的代码:Listlist=Arrays.asList(1,2,3,4,5);list.stream();现在,对于那些一直在使用流(java.util.stream)的人来说,它看起来既简单又干净,但我找不到实现的实际类java.util.Collection.stream()方法。当我说list.stream()时,我有以下问题:我从哪里得到java.util.stream.Stream?他们是如何在不实际“干扰”现有集合的情况下实现它的?(假设他们没有触及它们)我曾尝试查看java.util.AbstractCollecti