java8 stream sum multiple

Question

Мне любопытно, как суммировать несколько переменных в потоке java8.

Integer wCPU = 0; 
Double wnetwork = 0.0; 
Double wMem = 0.0; 

this.slaContractList.forEach(sla -> { 
    wCPU += sla.getNumberOfCPUs(); 
    wnetwork += sla.getNetworkBandwith(); 
    wMem += sla.getMemory(); 
}); 

Однако это не скомпилируется, так как переменная в выражении лямбда должна быть окончательной.

Answer 1

Предполагая slaContractList список SlaContract объектов, и имеет конструктор SlaContract(numberOfCPUs, networkBandwith, memory) вы можете:

SlaContract sumContract = slaContractList.stream() 
    .reduce(new SlaContract(0, 0.0, 0.0), (sla1, sla2) -> { 
     return new SlaContract(sla1.getNumberOfCPUs() + sla2.getNumberOfCPUs(), sla1.getworkBandwith() + sla2.getworkBandwith(), sla1.getMemory() + sla2.getMemory()); 
    }); 

Double wnetwork = sumContract.getworkBandwith(); 
Double wMem = sumContract.getMemory(); 
Integer wCPU = sumContract.getNumberOfCPUs(); 

То же самое решение, но для простого класса:

Point sumPoint = pointsList.stream() 
    .reduce(new Point(0, 0), (p1, p2) -> { 
     return new Point(p1.x + p2.x, p1.y + p2.y); 
    }); 

Answer 2

Попробуйте использовать Stream.reduce и Stream.sum:

Double wnetwork = slaContractList.stream() 
      .mapToDouble(sla -> sla.getNetworkBandwith()) 
      .sum(); 

Double wMem = slaContractList.stream() 
      .mapToDouble(sla -> sla.getMemory()) 
      .sum(); 

Integer wCPU = slaContractList.stream() 
      .mapToInt(sla -> sla.getNumberOfCPUs()) 
      .sum(); 

См https://docs.oracle.com/javase/tutorial/collections/streams/reduction.html

Преимущество использования потока является вариант использования parallelStream() вместо stream(). В некоторых ситуациях он может быть более эффективным, чем простой цикл.

Answer 3

Я хотел бы сделать простой хак, как это:

Integer[] wCPU = new Integer[1]; 
    Double[] wnetwork = new Double[1]; 
    Double[] wMem = new Double[1]; 

    this.slaContractList.forEach(sla -> { 
     wCPU[0] += sla.getNumberOfCPUs(); 
     wnetwork[0] += sla.getNetworkBandwith(); 
     wMem[0] += sla.getMemory(); 
    }); 

Это необязательно иметь final ключевое слово и, как и в Java-они ввели эффективно окончательный концепции. Это означает, что вы назначили только один раз.

Answer 4

Просто, чтобы сделать сумму, я бы использовал операцию суммирования потоков, как и в ответе Лукаса, но для более общего решения для решения «конечной проблемы» вы можете использовать классы java.util.concurrent.atomic. Он предназначен для использования в потоке и является потокобезопасным, поэтому его можно использовать в параллельном потоке.

AtomicInteger wCPU = new AtomicInteger(); 
DoubleAccumulator wnetwork = new DoubleAccumulator(Double::sum,0.d); 
DoubleAccumulator wMem = new DoubleAccumulator(Double::sum,0.d); 

this.slaContractList.forEach(sla -> { 
    wCPU.addAndGet(sla.getNumberOfCPUs()); 
    wnetwork.accumulate(sla.getNetworkBandwith()); 
    wMem.accumulate(sla.getMemory()); 
}); 

Теперь вы видите, что есть два вида реализации: Накопителя и атомная, выбор между этими 2 другим вопросом:

java 8 : Are LongAdder and LongAccumulator preferred to AtomicLong?