java8ストリームの合計倍数

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

は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(); 

は、ストリームを使用する利点は、代わりにstream()の使用parallelStream()のオプションですhttps://docs.oracle.com/javase/tutorial/collections/streams/reduction.html

を参照してください。状況によっては、単純なループよりも効率的である場合があります。

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(); 
    }); 

それは、彼らが効果的に最終概念を導入していたJava 8のように、両方のためのfinalキーワードを持っているオプションです。つまり、あなたは一度だけ割り当てられたことを意味します。 slaContractListを想定し

Answer 4

だけで合計を行うには、 Łukasz答えのようなストリームの合計演算を使用しますが、 "最終的な問題"を解決するためのより一般的な解決法では、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?