我正在寻找一种方法来实现非终端分组操作，这样内存开销就会最小。
例如，考虑 distinct()。在一般情况下，它别无选择，只能收集所有不同的项目，然后才将它们向前传输。但是，如果我们知道输入流已经排序，则可以使用最少的内存“即时”完成操作。
我知道我可以使用迭代器包装器并自己实现分组逻辑来为迭代器实现这一点。是否有更简单的方法来使用流 API 来实现这一点？
--编辑--
我找到了一种滥用 Stream.flatMap(..) 的方法来实现这一点:
private static class DedupSeq implements IntFunction<IntStream> {
private Integer prev;
@Override
public IntStream apply(int value) {
IntStream res = (prev != null && value == prev)? IntStream.empty() : IntStream.of(value);
prev = value;
return res;
}
}
然后:
IntStream.of(1,1,3,3,3,4,4,5).flatMap(new DedupSeq()).forEach(System.out::println);
打印:
1
3
4
5
通过一些更改，相同的技术可用于任何类型的内存高效序列流分组。无论如何，我不太喜欢这个解决方案，我一直在寻找更自然的东西(例如映射或过滤的工作方式)。此外，我在这里打破了约定，因为提供给 flatMap(..) 的函数是有状态的。
最佳答案
如果您想要一个不向不应该具有可变状态的函数添加可变状态的解决方案，您可以求助于collect:
static void distinctForSorted(IntStream s, IntConsumer action) {
s.collect(()->new long[]{Long.MIN_VALUE},
(a, i)->{ if(a[0]!=i) { action.accept(i); assert i>a[0]; a[0]=i; }},
(a, b)->{ throw new UnsupportedOperationException(); });
}
这是可行的，因为它是使用可变容器的预期方式，但是，它不能并行工作，因为在任意流位置拆分意味着有可能在两个(或更多)线程中遇到一个值。
如果您想要一个通用的 IntStream 而不是 forEach 操作，则首选 Spliterator 低级解决方案，尽管会增加复杂性。
static IntStream distinctForSorted(IntStream s) {
Spliterator.OfInt sp=s.spliterator();
return StreamSupport.intStream(
new Spliterators.AbstractIntSpliterator(sp.estimateSize(),
Spliterator.DISTINCT|Spliterator.SORTED|Spliterator.NONNULL|Spliterator.ORDERED) {
long last=Long.MIN_VALUE;
@Override
public boolean tryAdvance(IntConsumer action) {
long prev=last;
do if(!sp.tryAdvance(distinct(action))) return false; while(prev==last);
return true;
}
@Override
public void forEachRemaining(IntConsumer action) {
sp.forEachRemaining(distinct(action));
}
@Override
public Comparator<? super Integer> getComparator() {
return null;
}
private IntConsumer distinct(IntConsumer c) {
return i-> {
if(i==last) return;
assert i>last;
last=i;
c.accept(i);
};
}
}, false);
}
它甚至继承了并行支持，尽管它通过在另一个线程中处理它们之前预取一些值来工作，因此它不会加速 distinct 操作，但如果有计算，可能会加速后续操作激烈的。
为了完成，这里有一个针对任意(即未排序)IntStream 的独特操作，它不依赖于“装箱加 HashMap”，因此可能会有更好的效果内存占用:
static IntStream distinct(IntStream s) {
boolean parallel=s.isParallel();
s=s.collect(BitSet::new, BitSet::set, BitSet::or).stream();
if(parallel) s=s.parallel();
return s;
}
它仅适用于正 int 值；将其扩展到完整的 32 位范围将需要两个 BitSet，因此看起来不那么简洁，但通常用例允许将存储限制在 31 位范围内甚至更低......
关于Java Streams - 有效地对排序流上的项目进行分组，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/29588167/
很好奇，就使用rubyonrails自动化单元测试而言，你们正在做什么？您是否创建了一个脚本来在cron中运行rake作业并将结果邮寄给您？git中的预提交Hook？只是手动调用？我完全理解测试，但想知道在错误发生之前捕获错误的最佳实践是什么。让我们理所当然地认为测试本身是完美无缺的，并且可以正常工作。下一步是什么以确保他们在正确的时间将可能有害的结果传达给您？ 最佳答案 不确定您到底想听什么，但是有几个级别的自动代码库控制:在处理某项功能时，您可以使用类似autotest的内容获得关于哪些有效，哪些无效的即时反馈。要确保您的提
在控制台中反复尝试之后，我想到了这种方法，可以按发生日期对类似activerecord的(Mongoid)对象进行分组。我不确定这是完成此任务的最佳方法，但它确实有效。有没有人有更好的建议，或者这是一个很好的方法？#eventsisanarrayofactiverecord-likeobjectsthatincludeatimeattributeevents.map{|event|#converteventsarrayintoanarrayofhasheswiththedayofthemonthandtheevent{:number=>event.time.day,:event=>ev
如何在buildr项目中使用Ruby？我在很多不同的项目中使用过Ruby、JRuby、Java和Clojure。我目前正在使用我的标准Ruby开发一个模拟应用程序，我想尝试使用Clojure后端(我确实喜欢功能代码)以及JRubygui和测试套件。我还可以看到在未来的不同项目中使用Scala作为后端。我想我要为我的项目尝试一下buildr(http://buildr.apache.org/)，但我注意到buildr似乎没有设置为在项目中使用JRuby代码本身!这看起来有点傻，因为该工具旨在统一通用的JVM语言并且是在ruby中构建的。除了将输出的jar包含在一个独特的、仅限ruby
我正在编写一个包含C扩展的gem。通常当我写一个gem时，我会遵循TDD的过程，我会写一个失败的规范，然后处理代码直到它通过，等等......在“ext/mygem/mygem.c”中我的C扩展和在gemspec的“扩展”中配置的有效extconf.rb，如何运行我的规范并仍然加载我的C扩展？当我更改C代码时，我需要采取哪些步骤来重新编译代码？这可能是个愚蠢的问题，但是从我的gem的开发源代码树中输入“bundleinstall”不会构建任何native扩展。当我手动运行rubyext/mygem/extconf.rb时，我确实得到了一个Makefile(在整个项目的根目录中)，然后当
我在我的Rails项目中使用Pow和powifygem。现在我尝试升级我的ruby版本(从1.9.3到2.0.0，我使用RVM)当我切换ruby版本、安装所有gem依赖项时，我通过运行railss并访问localhost:3000确保该应用程序正常运行以前，我通过使用pow访问http://my_app.dev来浏览我的应用程序。升级后，由于错误Bundler::RubyVersionMismatch:YourRubyversionis1.9.3,butyourGemfilespecified2.0.0，此url不起作用我尝试过的:重新创建pow应用程序重启pow服务器更新战俘
我已经像这样安装了一个新的Rails项目:$railsnewsite它执行并到达:bundleinstall但是当它似乎尝试安装依赖项时我得到了这个错误Gem::Ext::BuildError:ERROR:Failedtobuildgemnativeextension./System/Library/Frameworks/Ruby.framework/Versions/2.0/usr/bin/rubyextconf.rbcheckingforlibkern/OSAtomic.h...yescreatingMakefilemake"DESTDIR="cleanmake"DESTDIR="
这是一道面试题，我没有答对，但还是很好奇怎么解。你有N个人的大家庭，分别是1,2,3,...,N岁。你想给你的大家庭拍张照片。所有的家庭成员都排成一排。“我是家里的friend，建议家庭成员安排如下:”1岁的家庭成员坐在这一排的最左边。每两个坐在一起的家庭成员的年龄相差不得超过2岁。输入:整数N，1≤N≤55。输出:摄影师可以拍摄的照片数量。示例->输入:4，输出:4符合条件的数组:[1,2,3,4][1,2,4,3][1,3,2,4][1,3,4,2]另一个例子:输入:5输出:6符合条件的数组:[1,2,3,4,5][1,2,3,5,4][1,2,4,3,5][1,2,4,5,3][
我已经构建了一些serverspec代码来在多个主机上运行一组测试。问题是当任何测试失败时，测试会在当前主机停止。即使测试失败，我也希望它继续在所有主机上运行。Rakefile:namespace:specdotask:all=>hosts.map{|h|'spec:'+h.split('.')[0]}hosts.eachdo|host|begindesc"Runserverspecto#{host}"RSpec::Core::RakeTask.new(host)do|t|ENV['TARGET_HOST']=hostt.pattern="spec/cfengine3/*_spec.r
我们的git存储库中目前有一个Gemfile。但是，有一个gem我只在我的环境中本地使用(我的团队不使用它)。为了使用它，我必须将它添加到我们的Gemfile中，但每次我checkout到我们的master/dev主分支时，由于与跟踪的gemfile冲突，我必须删除它。我想要的是类似Gemfile.local的东西，它将继承从Gemfile导入的gems，但也允许在那里导入新的gems以供使用只有我的机器。此文件将在.gitignore中被忽略。这可能吗？ 最佳答案 设置BUNDLE_GEMFILE环境变量:BUNDLE_GEMFI
这似乎非常适得其反，因为太多的gem会在window上破裂。我一直在处理很多mysql和ruby-mysqlgem问题(gem本身发生段错误，一个名为UnixSocket的类显然在Windows机器上不能正常工作，等等)。我只是在浪费时间吗？我应该转向不同的脚本语言吗？ 最佳答案 我在Windows上使用Ruby的经验很少，但是当我开始使用Ruby时，我是在Windows上，我的总体印象是它不是Windows原生系统。因此，在主要使用Windows多年之后，开始使用Ruby促使我切换回原来的系统Unix，这次是Linux。Rub