[rxJava 스터디 - 2장] 2장 예제 추가

lee-ji-hoon · lee-ji-hoon · commit e3f0069702f8 · 2023-04-22T22:28:33.000+09:00
diff --git a/src/main/kotlin/ezhoon/chapter02/2-11.kt b/src/main/kotlin/ezhoon/chapter02/2-11.kt
@@ -0,0 +1,14 @@
+package ezhoon.chapter02
+
+import java.util.concurrent.atomic.AtomicInteger
+
+class AtomicConsumer {
+
+    @Volatile
+    var count = AtomicInteger(0)
+        private set
+
+    fun increment() {
+        count.incrementAndGet()
+    }
+}
diff --git a/src/main/kotlin/ezhoon/chapter02/2-12.kt b/src/main/kotlin/ezhoon/chapter02/2-12.kt
@@ -0,0 +1,27 @@
+package ezhoon.chapter02
+
+import java.util.concurrent.Executors
+
+fun main() {
+
+    val counter = AtomicConsumer()
+
+    val task = Runnable {
+        for (i in 0..9999) {
+            counter.increment()
+        }
+    }
+
+    val executorService = Executors.newCachedThreadPool()
+
+    val future1 = executorService.submit(task, true)
+    val future2 = executorService.submit(task, true)
+
+    if (future1.get() && future2.get()) {
+        println("${counter.count}")
+    } else {
+        println("실패")
+    }
+
+    executorService.shutdown()
+}
diff --git a/src/main/kotlin/ezhoon/chapter02/2-13-2.kt b/src/main/kotlin/ezhoon/chapter02/2-13-2.kt
@@ -0,0 +1,31 @@
+package ezhoon.chapter02
+
+import java.util.concurrent.Executors
+
+fun main() {
+
+    val point = Point()
+
+    val task = Runnable {
+        for (i in 0..9999) {
+            point.rightUp()
+        }
+    }
+
+    val executorService = Executors.newCachedThreadPool()
+
+    val future1 = executorService.submit(task, true)
+    val future2 = executorService.submit(task, true)
+    val future3 = executorService.submit(task, true)
+    val future4 = executorService.submit(task, true)
+    val future5 = executorService.submit(task, true)
+    val future6 = executorService.submit(task, true)
+
+    if (future1.get() && future2.get() && future3.get() && future4.get() && future5.get() && future6.get()) {
+        println("${point.getX()},${point.getY()}")
+    } else {
+        println("실패")
+    }
+
+    executorService.shutdown()
+}
diff --git a/src/main/kotlin/ezhoon/chapter02/2-13.kt b/src/main/kotlin/ezhoon/chapter02/2-13.kt
@@ -0,0 +1,18 @@
+package ezhoon.chapter02
+
+import java.util.concurrent.atomic.AtomicInteger
+
+class Point {
+
+    private val x = AtomicInteger(0)
+    private val y = AtomicInteger(0)
+
+    fun rightUp() {
+        x.incrementAndGet()
+        y.incrementAndGet()
+    }
+
+    fun getX() = x.get()
+
+    fun getY() = y.get()
+}
diff --git a/src/main/kotlin/ezhoon/chapter02/2-5.kt b/src/main/kotlin/ezhoon/chapter02/2-5.kt
@@ -0,0 +1,12 @@
+package ezhoon.chapter02
+
+class Consumer {
+
+    @Volatile
+    var count: Int = 0
+        private set
+
+    fun increment() {
+        count++
+    }
+}
diff --git a/src/main/kotlin/ezhoon/chapter02/2-6.kt b/src/main/kotlin/ezhoon/chapter02/2-6.kt
@@ -0,0 +1,27 @@
+package ezhoon.chapter02
+
+import java.util.concurrent.Executors
+
+fun main() {
+
+    val counter = Consumer()
+
+    val task = Runnable {
+        for (i in 0..9999) {
+            counter.increment()
+        }
+    }
+
+    val executorService = Executors.newCachedThreadPool()
+
+    val future1 = executorService.submit(task, true)
+    val future2 = executorService.submit(task, true)
+
+    if (future1.get() && future2.get()) {
+        println("${counter.count}")
+    } else {
+        println("실패")
+    }
+
+    executorService.shutdown()
+}
diff --git a/src/main/kotlin/ezhoon/chapter02/README.md b/src/main/kotlin/ezhoon/chapter02/README.md
