인프런 커뮤니티 질문&답변

안녕하세요 선생님들 도움을 요청 하고자 질문글을 올립니다.

멀티 스레드 테스트 중 문제가 발생 했습니다.

서칭을 해보아도 문제 해결을 할 수 없어서 질문 드립니다.

멀티 스레드 모임 참가 테스트를 위해 테스트 코드를 짯습니다.

트랜잭션 어노테이션이 있을 경우 무한 대기에 빠지고 밑의 예외가 발생 합니다.

이상한점은 트랜잭션 어노테이션이 없거나 H2 DB 테스트를 하면 문제가 없습니다.

완성된 테스트도 H2 데이터 베이스는 통과 하지만 MySql 테스트를 하면 똑같이 무한 대기후

예외가 발생합니다. 이유가 뭘까요 ㅠㅠ 힌트라도 주시면 감사합니다.

void joinEventWhenParticipateAtTheSameTimeWithConcurrency() throws Exception {
    //given
    int taskCount = 5;
    ExecutorService executorService = Executors.newFixedThreadPool(5);
    CountDownLatch countDownLatch = new CountDownLatch(taskCount);

    Event findEvent = executorService.submit(() ->
            eventRepository.save(createEvent("테스터", "테스트 모임", 3))).get();

    executorService.shutdown();
}

java.util.concurrent.ExecutionException: org.springframework.dao.PessimisticLockingFailureException: could not execute statement
[Lock wait timeout exceeded; try restarting transaction]
Caused by: org.springframework.dao.PessimisticLockingFailureException: could not execute statement [Lock wait timeout exceeded; try restarting transaction]


@DisplayName("5명의 회원이 동시에 최대 인원이 3명인 모임에 참가 할때 3명만 참여 할 수 있다.")
@Test
void joinEventWhenParticipateAtTheSameTimeWithConcurrency() throws Exception {
        //given
        int taskCount = 5;
        ExecutorService executorService = Executors.newFixedThreadPool(5);
        CountDownLatch countDownLatch = new CountDownLatch(taskCount);

        Event findEvent = executorService.submit(() ->
                eventRepository.save(createEvent("테스터", "테스트 모임", 3))).get();

        List<User> users = executorService.submit(() -> Stream
                .generate(() -> {
                    User user = createUser("테스터", "testEmail");
                    userRepository.save(user);
                    return user;
                })
                .limit(taskCount)
                .toList()).get();

        //when
        AtomicInteger exceptionCount = new AtomicInteger(0);

        for (User user : users) {
            executorService.submit(() -> {
                try {
                    eventService.joinEvent(findEvent.getId(), user.getId());
                } catch (BusinessException ex) {
                    exceptionCount.incrementAndGet();
                } finally {
                    countDownLatch.countDown();  // 카운트다운
                }
            });
        }
        countDownLatch.await();

        Long participateCount = executorService.submit(
                () -> userEventRepository.countParticipantByEventId(findEvent.getId())).get();

        executorService.shutdown();

        //then
        assertThat(participateCount).isEqualTo(3);
        assertThat(exceptionCount.get()).isEqualTo(2);
    }