[BUG/ticket] 성공/실패 요청 수 측정 오류 해결

ticket/docker/docker-compose.yml

@@ -1,6 +1,7 @@
 version: "3.9"
 services:
   db:
+    container_name: ticket-db
     image: mysql:8.0.28
     platform: linux/x86_64
     restart: always

ticket/src/test/java/com/aengdulab/ticket/service/MemberTicketServiceConcurrencyTest.java

@@ -56,9 +56,7 @@ void setUp() {
 
         int threadCount = memberCount * MemberTicket.MEMBER_TICKET_COUNT_MAX;
         TimeMeasure.measureTime(() -> {
-            try (ExecutorService executorService = Executors.newFixedThreadPool(threadCount)) {
-                sendMultipleRequests(executorService, members, ticket);
-            }
+            sendMultipleRequests(threadCount, members, ticket);
         });
 
         assertThat(getTicketQuantity(ticket)).isEqualTo(0);
@@ -78,9 +76,7 @@ void setUp() {
 
         int threadCount = memberCount * ticketIssueCount;
         TimeMeasure.measureTime(() -> {
-            try (ExecutorService executorService = Executors.newFixedThreadPool(threadCount)) {
-                sendMultipleRequests(executorService, members, jupiterTicket, marsTicket);
-            }
+            sendMultipleRequests(threadCount, members, jupiterTicket, marsTicket);
         });
 
         assertThat(getTicketQuantity(jupiterTicket)).isGreaterThanOrEqualTo(0);
@@ -99,9 +95,7 @@ void setUp() {
 
         int threadCount = memberCount * MemberTicket.MEMBER_TICKET_COUNT_MAX;
         TimeMeasure.measureTime(() -> {
-            try (ExecutorService executorService = Executors.newFixedThreadPool(threadCount)) {
-                sendMultipleRequests(executorService, members, ticket);
-            }
+            sendMultipleRequests(threadCount, members, ticket);
         });
 
         assertThat(getTicketQuantity(ticket)).isEqualTo(0);
@@ -110,21 +104,23 @@ void setUp() {
         }
     }
 
-    private void sendMultipleRequests(ExecutorService executorService, List<Member> members, Ticket... tickets) {
+    private void sendMultipleRequests(Integer threadCount, List<Member> members, Ticket... tickets) {
         AtomicInteger succeedRequestCount = new AtomicInteger(0);
         AtomicInteger failRequestCount = new AtomicInteger(0);
 
-        for (Member member : members) {
-            for (int i = 0; i < MemberTicket.MEMBER_TICKET_COUNT_MAX; i++) {
-                executorService.submit(() -> {
-                    try {
-                        memberTicketService.issue(member.getId(), getRandomTicket(tickets).getId());
-                        succeedRequestCount.incrementAndGet();
-                    } catch (Exception e) {
-                        log.error("멤버 티켓 발행 중 오류 발생", e);
-                        failRequestCount.incrementAndGet();
-                    }
-                });
+        try (ExecutorService executorService = Executors.newFixedThreadPool(threadCount)) {
+            for (Member member : members) {
+                for (int i = 0; i < MemberTicket.MEMBER_TICKET_COUNT_MAX; i++) {
+                    executorService.submit(() -> {
+                        try {
+                            memberTicketService.issue(member.getId(), getRandomTicket(tickets).getId());
+                            succeedRequestCount.incrementAndGet();
+                        } catch (Exception e) {
+                            log.error("멤버 티켓 발행 중 오류 발생", e);
+                            failRequestCount.incrementAndGet();
+                        }
+                    });
+                }
             }
         }