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

현재 강의 내용을 바탕으로 OptimisticLock 을 구현중인데,
version이 증가하지 않는 이유를 알고 싶습니다.

도메인은 이렇습니다.

@Entity
@Table(name = "appointment")
public class Appointment extends BaseEntity {

    ...

    @OneToMany(mappedBy = "appointment")
    private List<AppointmentUser> appointmentUsers = new ArrayList<AppointmentUser>();

    @Version
    private Long version;

그리고, 레포지토리는 이렇습니다.

public interface AppointmentRepository extends JpaRepository<Appointment, Long> {

...

    @Lock(LockModeType.OPTIMISTIC)
    @Query("SELECT au FROM Appointment a " +
            "JOIN a.appointmentUsers au " +
            "WHERE au.id = :appointmentUserId ")
    AppointmentUser findByIdWithOptimisticLock(Long appointmentUserId);
}

그리고, 서비스 계층 메서드는 이렇습니다.

@Transactional(readOnly = true)
@Service
public class AppointmentUserService {

    ...

    @Transactional
    public void updateAuthority(Long appointmentId, Long loginMemberId, Long targetMemberId) {
        Member loginMember = memberRepository.getById(loginMemberId);
        Member targetMember = memberRepository.getById(targetMemberId);
        Appointment appointment = appointmentRepository.getById(appointmentId);
        AppointmentUser loginAppointmentUser = appointmentUserRepository.getByMemberAndAppointment(loginMember, appointment);
        AppointmentUser targetAppointmentUser = appointmentUserRepository.getByMemberAndAppointment(targetMember, appointment);

        validateIsAdminMember(loginAppointmentUser.getId());
        MemberAuthority targetAuthority = targetAppointmentUser.getMemberAuthority();

        targetAppointmentUser.updateAuthority(MemberAuthority.getAnotherAuthority(targetAuthority));
        appointmentUserRepository.save(targetAppointmentUser);
    }

    private void validateIsAdminMember(Long loginAppointmentUserId) {
        if (appointmentRepository.findByIdWithOptimisticLock(loginAppointmentUserId).getMemberAuthority() != MemberAuthority.ADMIN) {
            throw new NotAdminMemberException();
        }
    }
}

위 updateAuthority 메서드 내에서 validateIsAdminMember를 호출하여, validateIsAdminMember 안에 있는 findByIdWithOptimisticLock을 통하여 Version을 올려주어서 낙관적 락을 성공적으로 구현할 수 있을 줄 알았는데 테스트를 해보니 아래와 같이 실패합니다..

@Test
void 동시성_테스트() throws InterruptedException {
    Logger logger = Logger.getLogger(MultiThreadTest.class.getName());

    ExecutorService executorService = Executors.newFixedThreadPool(2);
    CountDownLatch latch = new CountDownLatch(2);

    AtomicReference<Boolean> flag = new AtomicReference<>(false);

    executorService.execute(() -> {
        try {
            logger.log(Level.INFO, "첫 번째 요청 시작: member1 -> member2");
            logger.log(Level.INFO, "버전1전" + appointmentRepository.getById(1L).getVersion());
            appointmentUserService.updateAuthority(1L, 1L, 2L);
            logger.log(Level.INFO, "버전1완" + appointmentRepository.getById(1L).getVersion());
            logger.log(Level.INFO, "첫 번째 요청 완료: member1 -> member2");
        } catch (Exception e) {
            logger.log(Level.SEVERE, "첫 번째 요청 중 예외 발생", e);
            flag.set(true);
        } finally {
            latch.countDown();
        }
    });

    executorService.execute(() -> {
        try {
            logger.log(Level.INFO, "두 번째 요청 시작: member2 -> member1");
            logger.log(Level.INFO, "버전2전" + appointmentRepository.getById(1L).getVersion());
            appointmentUserService.updateAuthority(1L, 2L, 1L);
            logger.log(Level.INFO, "버전2완" + appointmentRepository.getById(1L).getVersion());
            logger.log(Level.INFO, "두 번째 요청 완료: member2 -> member1");
        } catch (Exception e) {
            logger.log(Level.SEVERE, "두 번째 요청 중 예외 발생", e);
            flag.set(true);
        } finally {
            latch.countDown();
        }
    });

    latch.await();
};

위와 같이, 두 개의 스레드에서 진행을 하였고, 각 스레드 내에서 updateAuthority()를 실행 전후에 version을 찍어보았으나, 찍힌 4개의 version 모두 0이 나왔고 또한, 동시성 제어도 안되는 상황입니다.

왜 0이 나오는걸까요.. 궁금합니다!

(컴파일 에러는 없습니다)