背景：之前和同事討論一個問題，他們公司調研中發現forEach的速度比for的速度慢，當剛聽到這個結論的時候有點詫異，因為之前看過國外的文章和他們公司的結論一樣，但是測驗用例單一，今天正好在看flink相關的流處理，正好想起來了這個問題，然后簡單的寫了一個demo來進行推翻這個結論，
廢話不多說直接上代碼吧，
package pers.bik.flink;
import java.util.ArrayList;
import java.util.List;
import java.util.concurrent.atomic.AtomicInteger;
import java.util.stream.IntStream;
/**
* @author yangkaifei
* @date 2021/8/10 11:28 下午
* @cersion 1.0
*/
public class Test {
public static void main(String[] args) {
List<Integer> list = new ArrayList<>();
IntStream.range(0, 1000).forEach(number -> list.add(number));
streamForEach(list);
parallelStreamForEach(list);
forI(list);
strengthFor(list);
}
/**
* 串行流forEach
* @param list
*/
private static void streamForEach(List<Integer> list) {
AtomicInteger i = new AtomicInteger();
long startTime = System.currentTimeMillis();
list.stream().forEach(number -> {
String s = String.valueOf(number);
i.getAndIncrement();
});
long endTime = System.currentTimeMillis();
System.out.println(String.format("streamForEach:%s", endTime - startTime));
}
/**
* 并行流forEach
* @param list
*/
private static void parallelStreamForEach(List<Integer> list) {
AtomicInteger i = new AtomicInteger();
long startTime = System.currentTimeMillis();
list.parallelStream().forEach(number -> {
String s = String.valueOf(number);
i.getAndIncrement();
});
long endTime = System.currentTimeMillis();
System.out.println(String.format("parallelStreamForEach:%s", endTime - startTime));
}
/**
* for i
* @param list
*/
private static void forI(List<Integer> list) {
AtomicInteger i = new AtomicInteger();
long startTime = System.currentTimeMillis();
for (int j = 0; j < list.size(); j++) {
String s = String.valueOf(list.get(j));
i.getAndIncrement();
}
long endTime = System.currentTimeMillis();
System.out.println(String.format("forI:%s", endTime - startTime));
}
/**
* 增強for回圈
* @param list
*/
private static void strengthFor(List<Integer> list) {
AtomicInteger i = new AtomicInteger();
long startTime = System.currentTimeMillis();
for (Integer integer : list) {
String s = String.valueOf(integer);
i.getAndIncrement();
}
long endTime = System.currentTimeMillis();
System.out.println(String.format("strengthFor:%s", endTime - startTime));
}
}
運行結果：
streamForEach:2041
parallelStreamForEach:352
forI:468
strengthFor:411結論：
對于for、增強for回圈、forEach不能單純的拋開業務場景就去肯定的給出一個結論，forEach的速度未必就比for回圈慢，
當我再次調整，將數量調整為1000的時候，運行的結果又會發生變化
IntStream.range(0, 1000).forEach(number -> list.add(number));運行結果
streamForEach:1
parallelStreamForEach:4
forI:0
strengthFor:1對比兩個不同的資料量，運行的結果也不盡相同（當然代碼有些不嚴謹，但是完全可以推翻forEach一定比for慢的結論，或者說A一定比B快的結論），
在軟體開發中，對于一切別人給定的結論我們要抱著質疑的態度，只有當自己親身去調研的時候才能說服自己，
有時間在寫背后的原理，先睡覺吧狗命要緊，，，
轉載請註明出處，本文鏈接：https://www.uj5u.com/qita/293315.html
標籤：其他
上一篇：Hadoop之HDFS