20241218 동시성 병렬성 연

Author: LimZida

src/main/java/io/concurrency/chapter01/exam01/ConcurrencyExample.java

@@ -2,11 +2,18 @@
 
 import java.util.ArrayList;
 import java.util.List;
-
+/*
+* 동시성 - CPU 개수 < 작업의 개수에 최적화 되어있습니다.
+*
+* 만약 CPU 개수보다 작업의 개수가 한개라도 많다면 동시성 처리로 진행된다.
+* */
 public class ConcurrencyExample {
     public static void main(String[] args) {
-
+        System.out.println("CPU 개수 : "+Runtime.getRuntime().availableProcessors());
+        // CPU 개수 * 2
 //        int cpuCores = Runtime.getRuntime().availableProcessors() * 2;
+
+        // CPU 개수 + 1
         int cpuCores = 13;
 
         // CPU 개수를 초과하는 데이터를 생성

src/main/java/io/concurrency/chapter01/exam01/ParallelismExample.java

@@ -2,10 +2,13 @@
 
 import java.util.ArrayList;
 import java.util.List;
-
+/*
+* 병렬성 - CPU 개수 >= 작업의 개수에 최적화 되어있습니다.
+* */
 public class ParallelismExample {
     public static void main(String[] args) {
-//        int cpuCores = 1;
+        System.out.println("CPU 개수 : "+Runtime.getRuntime().availableProcessors());
+
         int cpuCores = Runtime.getRuntime().availableProcessors();
 
         // CPU 개수만큼 데이터를 생성
@@ -16,7 +19,15 @@ public static void main(String[] args) {
 
         // CPU 개수만큼 데이터를 병렬로 처리
         long startTime1 = System.currentTimeMillis();
-        long sum1 = data.parallelStream()
+
+        /*
+        * 병렬스트림 진행 (CPU를 전부 사용해서 각각 작업을 하나씩 물기)
+        * */
+//        long sum1 = data.parallelStream()
+        /*
+        * 일반스트림 진행 (CPU를 하나만 사용해서 작업을 진행)
+        * */
+        long sum1 = data.stream()
                 .mapToLong(i -> {
                     try {
                         Thread.sleep(500);