小编hol*_*ava的帖子

我想了解flatMap使用Collectors 执行一段时间的方法.这是一个例子.

场景:

我有以下接口:

interface Ic {
    //empty
}

interface Ib {
    Stream<Ic> getCs();
}

interface Ia {
    String getName();
    Stream<Ib> getBs();
}

我正在尝试实现以下方法:

Map<String, Long> total_of_C_per_A (Stream<Ia> streamOfA) {
   return streamOfA.collect(groupBy(Ia::getName, ???));
}

该分类功能相当straitforward,我的问题是与下游收集器.我需要计算与"A"相关的"C"数.

我试图:

如果我想简单地返回计数而不创建地图,我会这样做:

streamOfA
  .flatMap(Ia::getBs)
  .flatMap(Ib::getCs)
  .count();

但是这个Collectors类只允许我做映射操作.我还能尝试做些什么？

谢谢.

我需要根据一些数学函数生成整数流，每个值都基于之前的值。

例如 - 假设我想取最后一个数字并加 10：[1, 11, 21, 31, 41, ...]

当然真正的功能要复杂得多。

我尝试以斐波那契为例，但无法使其工作：

Stream.iterate(new long[]{ 1, 1 }, p->new long[]{ p[1], p[0]+p[1] })
      .limit(92).forEach(p->System.out.println(p[0]));

我只能从1开始。

这是我尝试做的：

Stream.iterate(new long[]{ 1 }, p-> {p[0], p[0] + 10})
.limit(4).forEach(p->System.out.println(p[0]));

请帮助我理解kotlin文档中的这段代码: -

val a: Int = 10000
print(a === a) // Prints 'true'
val boxedA: Int? = a
val anotherBoxedA: Int? = a
print(boxedA === anotherBoxedA) // !!!Prints 'false'!!!

现在,我明白,int a = 10000在下一行中它首先使用它进行比较===.

现在问题是为什么当它被分配时boxedA=a,它检查它是否为空使用int?.可以这样写: -

val boxedA: Int=a

如果我以错误的方式理解它,有人指导检查正确的地方或为我解释一下.

我知道Class.getDeclaredClasses()可以获得它声明但不包括匿名类的所有类.

我想知道有没有办法通过封闭的类获得所有封闭的类？例如,我想获得Root为测试目的定义的所有封闭类.

class Root{
   void run(){
      Runnable task = new Runnable(){
         public void run(){}
      };

      task.getClass().getEnclosingClass();// return Root.class
      // but I want to get all enclosed class via Root.class, for example:
     // Root.class... == task.getClass() 
   }
}

预期的结果是:[class of task].

我是新手 科特林当我开始Null Safety时,我对下面的情况感到困惑.

关于初始化存在一些数据不一致(在构造函数中可用的未初始化的某些地方).

任何人都可以更详细地描述这种情况吗？

假设我有如下代码:

Future<Object> executeBy(ExecutorService executor) {
    return executor.submit(() -> {
        throw new IllegalStateException();
    });
}

使用ForkJoinPool#commonPool时没有问题,但是当我使用并行性时ForkJoinPool它会加倍IllegalStateException.例如:

executeBy(new ForkJoinPool(1)).get(); 
//                              ^--- double the IllegalStateException

Q1:为什么并行ForkJoinPool一倍Exception发生在Callable？

Q2:如何避免这种奇怪的行为？

我试图了解流中的 reduce 方法是如何工作的。

Stream.of(1,2,3,4,5,6,7).reduce(new ArrayList<>(),
(List<Integer> l, Integer a) -> {l.add(a);return l;},
(List<Integer> l1, List<Integer> l2) -> {
System.out.println("l1 is" + l1 + "l2 is " + l2);
l1.addAll(l2);
return l1;
}).forEach(System.out::println);

该行System.out.println("l1 is" + l1 + "l2 is " + l2)永远不会被打印。我可以理解发生了什么，(List<Integer> l, Integer a) -> {l.add(a);return l;}
有人可以解释为什么没有打印出来吗？java文档说function for combining two values, which must be compatible with the accumulator function

谢谢，阿马尔