标签: java-stream

从这个链接,我只是部分理解,至少在某些时候,java嵌套并行流存在问题.但是,我无法推断出以下问题的答案:

假设我有一个外部srtream和一个内部流,两者都使用并行流.事实证明,根据我的计算,如果内部流首先完全并行完成,那么它将更高效(由于数据位置,即L1/L2/L3 CPU缓存中的缓存)(如果且仅cpu核心可用)做外部流.我认为这对大多数人的情况都是如此.所以我的问题是:

Java会首先并行执行内部流,然后在outerstream上工作吗？如果是这样,它是在编译时还是在运行时做出决定？如果在运行时,JIT甚至足够聪明地意识到如果内部流确实具有比核心数量(32)更多的元素(例如数百个),那么它肯定应该使用所有32个内核来处理在从外部流移动下一个元素之前的内部流; 但是,如果元素的数量很小(例如<32),则可以"并行处理"来自"下一个"外部流的元素的元素.

我被告知不要.anyMatch(Predicate.isEqual(true))被同事使用.原因是,它不是无效的.他们建议我应该使用Optional<Boolean>.

我有一个帐户列表,我想true只有在帐户有未偿还的活跃贷款时才返回布尔值,否则返回false.

@Data
public class Account {
    private String accountNumber;
    @Getter(AccessLevel.NONE)
    private Boolean activeLoan;
    private String accountReference;
    private Double balance;
    private String status;

    public Boolean hasActiveLoan() {
        return activeLoan;
    }
}

换句话说,只有当hasActiveLoan()等于真时.

以下是我提出的解决方案:

 Boolean checkActiveLoanRule(List<Account> accounts) {

         Optional<Boolean> loanAccountExists = Optional.of(accounts.stream()
                .map(Account::hasActiveLoanAccount)
                .anyMatch(Predicate.isEqual(true)));

         return loanAccountExists.equals(Optional.of(true));
     }

这可以重构以某种方式改进吗？还有其他想法吗？

最重要的是,这样的解决方案是线程安全的吗？

我有一个用例需要在这个对象中总结不同的字段,所以我这样编码,我可以把它放在一个流中吗？

int totalUnits = records.stream()
        .mapToInt(DynamoSalesAggregateSummaryRecord::getUnits).sum();
int totalReturns = records.stream()
        .mapToInt(DynamoSalesAggregateSummaryRecord::getReturns).sum();
int totalCancellations = records.stream()
        .mapToInt(DynamoSalesAggregateSummaryRecord::getCancellations).sum();
BigDecimal totalRevenue = records.stream()
        .map(DynamoSalesAggregateSummaryRecord::getRevenue)
        .reduce(BigDecimal.ZERO, BigDecimal::add);
BigDecimal totalRoyalties = records.stream()
        .map(DynamoSalesAggregateSummaryRecord::getRoyalties)
        .reduce(BigDecimal.ZERO, BigDecimal::add);

我试图找出一个简单的转换的最优雅的方式int排列(例如{1, 2, 3}),以一个简单的String阵列(例如,{"id", "1", "id", "2", "id", "3"}使用Java 8流串对).

传统上代码如下: -

int[] input = {1, 2, 3};

String[] output = new String[input.length * 2];

int i = 0;
for (int val : input) {
    output[i++] = "id";
    output[i++] = String.valueOf(val);
}

但假设这可以在Java 8中用1-liner完成.

例如,考虑下面的代码

List<Reference> references = context.getReferences()
                .stream()
                .filter(ref -> ref.getCondition() == SOMETHING_DESIRABLE)
                .collect(Collectors.toList());

现在,如果我改变引用列表中的每个引用,它是否会反映在原始context.references中？

我有一个以下类型的嵌套Map LinkedHashMap<String, LinkedHashMap<String, ArrayList<Commit>>>.第一个映射的键存储一些用户名,第二个映射的键是用户的存储库名称,在ArrayList内部我有一个对象,其中包含一些属性,如哈希,消息,添加等.

在我按照第一张地图的键和第二张地图的键按字母顺序排序整个集合后,我如何在相同类型的新集合中收集(保存)我的嵌套地图(对象保持不变)？

我需要使用lambda和Stream API来做到这一点.这是我试图这样做的方式:

LinkedHashMap<String, LinkedHashMap<String, ArrayList<Commit>>> sorted = gitUsers.entrySet()
            .stream()
            .sorted((u1, u2) -> u1.getKey().compareTo(u2.getKey()))
            .map(u -> u.getValue()
                    .entrySet()
                    .stream()
                    .sorted((r1, r2) -> collator.compare(r1.getKey(), r2.getKey())))
            .collect(Collectors.toMap(Map.Entry::getKey, Map.Entry::getValue,(a, b) -> a, LinkedHashMap::new));

我肯定做错了,因为我不断收到以下消息"无法从静态上下文中引用非静态方法"并且无法收集地图.我想我无法成功组装我的地图因为.map()我使用的功能和第二个流.

我知道你会建议我使用TreeMap或者使用.foreach()我的lambda中的方法对它进行排序并立即打印(顺便提一下我已经做过),但我需要像上面描述的那样完全按照这种方式进行排序..

出于我的编程基础课程的目的,这个问题应该以这种方式解决.希望对你有所帮助!

PS我一直在寻找解决方案很长一段时间,并在各地进行研究,包括Stack Overflow论坛,并没有找到任何对应于所要求的解决问题的方法.

我想我已经陷入困境。由于性能原因，我正在尝试利用Java parallelStream。

函数Specimen.pick（）采样并返回Specimen的实例。我想在替换pool时使用parallelStream对此进行并行化。

var pool: Array<Specimen> = Array(100_000) .. 

这就是我要在Kotlin中编写的内容：

pool = pool.asList().parallelStream().map { Specimen.pick(pool, wheel, r.split()) }.toArray(Specimen::new)

:: new出现了哪些错误

pool = pool.asList().parallelStream().map { Specimen.pick(pool, wheel, r.split()) }.collect(Collectors.toList()).toTypedArray()

Person[] men = people.stream()
                      .filter(p -> p.getGender() == MALE)
                      .toArray(Person[]::new);

val men = people.stream()
            .filter({ p -> p.getGender() === MALE })
            .toArray(Person[]::new  /* Currently unsupported in Kotlin */)