Java 8 Parallel Stream Basic Usage & Perf. Test

	public class Main {
	public static void main (String[] args) {
	Stomach stomach = new Stomach ();
	long startTime = System.currentTimeMillis ();
	for (int i = 0; i < 10000; i++) {
	stomach.accept (new Salad ());
	stomach.accept (new Burger ());
	}
	long normalDigestionDuration = System.currentTimeMillis () - startTime;
	//------------------------------------------------------------------------------------------
	Consumer<Food> c = (Food food)-> {
	System.out.println ("Eating the " +food);
	};
	List<Food> foods = new ArrayList<> ();
	for (int i = 0; i < 10000; i++) {
	stomach.accept (new Salad ());
	stomach.accept (new Burger ());
	}
	startTime = System.currentTimeMillis ();
	foods.parallelStream ().map (food->{consumeFood (food,c);return food;}).count ();
	long paralelStreamDigestDuration = System.currentTimeMillis () - startTime;
	//------------------------------------------------------------------------------------------
	System.out.println ("Digestion duration is :" + normalDigestionDuration);// ~120 ms
	System.out.println ("Digestion with parallel stream = " + paralelStreamDigestDuration);// ~7 ms...so fast huh ?
	}
	public static void consumeFood (Food food, Consumer<Food> consumer){
	consumer.accept (food);
	}
	}
	Outputs::
	Digestion duration is :120
	Digestion with parallel stream = 7

view raw ParallelStreamTest.java hosted with ❤ by GitHub