From 7b4302350bacedf3f2d5dc4f48a9c7c7cb55cc58 Mon Sep 17 00:00:00 2001 From: seokjin8678 Date: Wed, 12 Jun 2024 17:08:22 +0900 Subject: [PATCH] =?UTF-8?q?fix:=20TicketSequence=20=EA=B5=AC=ED=98=84=20De?= =?UTF-8?q?que=EB=A1=9C=20=EB=8F=99=EC=9E=91=ED=95=98=EB=8F=84=EB=A1=9D=20?= =?UTF-8?q?=EB=B3=80=EA=B2=BD?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../infrastructure/sequence/RedisTicketSequence.java | 2 +- .../infrastructure/sequence/MemoryTicketSequence.java | 10 +++++----- 2 files changed, 6 insertions(+), 6 deletions(-) diff --git a/backend/src/main/java/com/festago/ticketing/infrastructure/sequence/RedisTicketSequence.java b/backend/src/main/java/com/festago/ticketing/infrastructure/sequence/RedisTicketSequence.java index 6d8dabe6c..8b2725523 100644 --- a/backend/src/main/java/com/festago/ticketing/infrastructure/sequence/RedisTicketSequence.java +++ b/backend/src/main/java/com/festago/ticketing/infrastructure/sequence/RedisTicketSequence.java @@ -33,7 +33,7 @@ public int reserve() { @Override public void cancel(int sequence) { - redisTemplate.opsForList().leftPush(key, String.valueOf(sequence)); + redisTemplate.opsForList().rightPush(key, String.valueOf(sequence)); } @Override diff --git a/backend/src/test/java/com/festago/ticketing/infrastructure/sequence/MemoryTicketSequence.java b/backend/src/test/java/com/festago/ticketing/infrastructure/sequence/MemoryTicketSequence.java index a04fc974a..0b7977ed6 100644 --- a/backend/src/test/java/com/festago/ticketing/infrastructure/sequence/MemoryTicketSequence.java +++ b/backend/src/test/java/com/festago/ticketing/infrastructure/sequence/MemoryTicketSequence.java @@ -3,17 +3,17 @@ import com.festago.common.exception.BadRequestException; import com.festago.common.exception.ErrorCode; import com.festago.ticketing.domain.TicketSequence; +import java.util.Deque; import java.util.List; -import java.util.Queue; -import java.util.concurrent.ArrayBlockingQueue; +import java.util.concurrent.LinkedBlockingDeque; import java.util.stream.IntStream; public class MemoryTicketSequence implements TicketSequence { - private final Queue queue; + private final Deque queue; public MemoryTicketSequence(int quantity) { - this.queue = new ArrayBlockingQueue<>(quantity); + this.queue = new LinkedBlockingDeque<>(quantity); List sequences = IntStream.rangeClosed(1, quantity) .boxed() .toList(); @@ -36,7 +36,7 @@ public int reserve() { @Override public void cancel(int sequence) { - queue.offer(sequence); + queue.addFirst(sequence); } @Override