서비스 로직에서 saveAndFlush 질문입니다.

SynchronizdeFacade를 만들어서 래핑해주면 save 메소드를 사용하는것이 이해가 안갑니다. 혹시 설명이 가능할까요? 효율성의 측면에서 save가 좋아서 save를 이용하려고 하는데 말씀하신것처럼 해당 메소드를 사용하기 위해서 SynchronizdeFacade이 필요한데 해당 내용에 대해 이해가 안가서 댓글을 남깁니다.

하지홍님 안녕하세요.
제가 댓글에서 말한 것처럼 save 메소드를 사용하게 된다면 데이터베이스에 바로 데이터를 업데이트 하는게 아니기 때문에 DB 에 값이 업데이트 되기전에 다른 스레드가 메소드에 접근이 가능해집니다.
A 스레드가 수량을 99개로 업데이트를 완료하기 이전에 B 스레드가 수량이 100개인 데이터를 읽을 수 있다는 뜻입니다.
이로인해서 레이스컨디션이 발생하게 됩니다.

감사합니다.

답변 매우 감사합니다 :)

마지막으로 질문이 있습니다. 멀티스레드 환경에서 잘 작동할 수 있도록 과정과 해결방안을 설명해주셨는데 예로서 낙관적 락을 적용하여 갱신손실 문제를 해결해주는데 테스트코드에서는 Executors를 사용해서 멀티스레드 환경을 만들어 주었습니다. 그러면 테스트코드가 아니라 실제 비즈니스 로직(서비스단)에서 멀티스레드 환경을 따로 만들어 주어야 하는 건가요? 예로서 Executors를 사용하거나 SpringAsyncConfig을 만들어서 해결해야 하나요? 강의 내에서는 테스트 코드에서만 멀티스레드환경만 구축된 것인가 궁금해서 적습니다.

예시)

@Slf4j
@Service
@RequiredArgsConstructor
public class OrderService {

    private final OrderRepository orderRepository;
    private final ItemRepository itemRepository;
    private final MemberService memberService;


    @Transactional
    public Item decreaseStock(Long id, int quantity) {
        Item item = itemRepository.findByIdWithOptimisticLock(id).orElseThrow();
        item.decrease(quantity);
        return item;
    }



    @Transactional
    @Async("threadPoolTaskExecutor")
    public Order createOrder(UserDetails userDetails, OrderRequest orderRequest) {
        Member member = memberService.findByEmail(userDetails.getUsername())
                .orElseThrow(() -> new CustomException(ErrorCode.MEMBER_NOT_FOUND));
        Item item = decreaseStock(orderRequest.getItemId(), orderRequest.getItemNumber());
        OrderItem orderItem = OrderItem.createOrderItem(item, item.getPrice(), orderRequest.getItemNumber());

        Order order = Order.createOrder(member, orderItem);
        orderRepository.save(order);
        return order;
    }
}

@Configuration
public class SpringAsyncConfig {

    @Bean(name = "threadPoolTaskExecutor")
    public Executor threadPoolTaskExecutor() {
        ThreadPoolTaskExecutor taskExecutor = new ThreadPoolTaskExecutor();
        taskExecutor.setCorePoolSize(10);
        taskExecutor.setMaxPoolSize(100);
        taskExecutor.setQueueCapacity(1000);
        taskExecutor.setThreadNamePrefix("Executor-");
        taskExecutor.initialize();
        return taskExecutor;
    }
}

테스트코드에서는 여러 사용자가 동시에 요청을 보내는것을 가정하기 위하여 멀티스레드를 사용한 것 입니다.
따라서, 비즈니스 로직에서는 별도의 스레드풀을 사용하지 않아도 됩니다.