[2장] Point 예제 Java 로 테스트

audxo112 · audxo112 · commit e25bcc72aa2e · 2023-04-29T19:09:14.000+09:00
diff --git a/src/main/java/kms/chapter02/Point.java b/src/main/java/kms/chapter02/Point.java
@@ -0,0 +1,26 @@
+package kms.chapter02;
+
+import java.util.concurrent.atomic.AtomicInteger;
+
+public class Point {
+    private final AtomicInteger x = new AtomicInteger(0);
+    private final AtomicInteger y = new AtomicInteger(0);
+
+    void rightUp() {
+        x.incrementAndGet();
+        y.incrementAndGet();
+    }
+
+    int getX() {
+        return x.get();
+    }
+
+    int getY() {
+        return y.get();
+    }
+
+    @Override
+    public String toString() {
+        return String.format("%d, %d", getX(), getY());
+    }
+}
diff --git a/src/main/java/kms/chapter02/PointSample.java b/src/main/java/kms/chapter02/PointSample.java
@@ -0,0 +1,31 @@
+package kms.chapter02;
+
+import java.util.concurrent.ExecutorService;
+import java.util.concurrent.Executors;
+import java.util.concurrent.Future;
+
+public class PointSample {
+
+    public static void main(String[] args) throws Exception {
+        final Point pos = new Point();
+
+        Runnable task = () -> {
+            for(int i = 0; i < 10000 ; i++) {
+                pos.rightUp();
+            }
+        };
+
+        ExecutorService executorService = Executors.newCachedThreadPool();
+
+        Future<Boolean> future1 = executorService.submit(task, true);
+        Future<Boolean> future2 = executorService.submit(task, true);
+
+        if(future1.get() && future2.get()) {
+            System.out.println(pos);
+        } else {
+            System.out.println("failed");
+        }
+
+        executorService.shutdown();
+    }
+}
