Test: 스레드 개수 및 충전/사용 금액을 변수로 추출하여 동시성 테스트 개선

- threadcount 변수를 도입하여 스레드 풀의 크기를 유연하게 조정할 수 있도록 수정
- amountPerThread 변수를 사용하여 각 스레드에서 충전/사용할 금액을 변수화
- 하드코딩 된 값을 제거하여 assertion 실수를 방지하고 테스트 코드의 가독성과 유지보수성을 향상시킴

Author: itstimi-XD

Diff for: src/test/kotlin/io/hhplus/tdd/point/PointServiceConcurrencyTest.kt

@@ -1,10 +1,10 @@
 package io.hhplus.tdd.point
 
-import org.junit.jupiter.api.Assertions.*
+import org.junit.jupiter.api.Assertions.assertEquals
 import org.junit.jupiter.api.BeforeEach
 import org.junit.jupiter.api.Test
-import org.springframework.boot.test.context.SpringBootTest
 import org.springframework.beans.factory.annotation.Autowired
+import org.springframework.boot.test.context.SpringBootTest
 import java.util.concurrent.Executors
 import java.util.concurrent.TimeUnit
 
@@ -15,6 +15,8 @@ class PointServiceConcurrencyTest {
     private lateinit var pointService: PointService
 
     private val userId = 1L
+    private val threadCount = 10 // 스레드 개수를 변수로 선언
+    private val amountPerThread = 10L // 각 스레드마다 충전/사용할 금액을 변수로 선언
 
     // 각 테스트 전에 초기 포인트를 설정하는 메소드
     @BeforeEach
@@ -25,16 +27,16 @@ class PointServiceConcurrencyTest {
 
     @Test
     fun `동시 충전 테스트`() {
-        // 10개의 스레드를 생성하여 동시에 충전 요청을 보내기 위해 ThreadPool을 생성
-        val executor = Executors.newFixedThreadPool(10)
+        // ThreadPool을 생성
+        val executor = Executors.newFixedThreadPool(threadCount)
 
         // 초기 포인트를 가져옴
-        val initialPoints = pointService.getUserPoint(1L).point
+        val initialPoints = pointService.getUserPoint(userId).point
 
-        // 10개의 스레드가 동시에 10포인트씩 충전
-        repeat(10) {
+        // 스레드마다 설정된 금액을 동시에 충전
+        repeat(threadCount) {
             executor.submit {
-                pointService.charge(1L, 10)
+                pointService.charge(userId, amountPerThread)
             }
         }
 
@@ -43,23 +45,23 @@ class PointServiceConcurrencyTest {
         executor.awaitTermination(1, TimeUnit.MINUTES)
 
         // 최종 포인트를 가져와서 10번의 충전 후 예상되는 포인트 값과 일치하는지 확인
-        val finalPoints = pointService.getUserPoint(1L).point
-        // 10개의 요청이 모두 완료된 후의 최종 포인트 값이 올바른지 확인
-        assertEquals(initialPoints + 100, finalPoints)  // 10개의 요청, 각각 10포인트 충전
+        val finalPoints = pointService.getUserPoint(userId).point
+        // 예상 포인트 값이 정확한지 검증
+        assertEquals(initialPoints + (threadCount * amountPerThread), finalPoints)
     }
 
     @Test
     fun `동시 사용 테스트`() {
-        // 10개의 스레드를 생성하여 동시에 사용 요청을 보내기 위해 ThreadPool을 생성
-        val executor = Executors.newFixedThreadPool(10)
+        // ThreadPool을 생성
+        val executor = Executors.newFixedThreadPool(threadCount)
 
         // 초기 포인트를 가져옴
-        val initialPoints = pointService.getUserPoint(1L).point
+        val initialPoints = pointService.getUserPoint(userId).point
 
-        // 10개의 스레드가 동시에 10포인트씩 사용
-        repeat(10) {
+        // 스레드마다 설정된 금액을 동시에 사용
+        repeat(threadCount) {
             executor.submit {
-                pointService.use(1L, 10)
+                pointService.use(userId, amountPerThread)
             }
         }
 
@@ -68,8 +70,8 @@ class PointServiceConcurrencyTest {
         executor.awaitTermination(1, TimeUnit.MINUTES)
 
         // 최종 포인트를 가져와서 10번의 사용 후 예상되는 포인트 값과 일치하는지 확인
-        val finalPoints = pointService.getUserPoint(1L).point
-        // 10개의 요청이 모두 완료된 후의 최종 포인트 값이 올바른지 확인
-        assertEquals(initialPoints - 100, finalPoints)  // 10개의 요청, 각각 10포인트 사용
+        val finalPoints = pointService.getUserPoint(userId).point
+        // 예상 포인트 값이 정확한지 검증
+        assertEquals(initialPoints - (threadCount * amountPerThread), finalPoints)
     }
 }