commit

src/main/java/com/sxtvs/api/chatgpt/service/ChatGptService.java

@@ -20,6 +20,7 @@ import org.springframework.web.bind.annotation.RequestBody;
 import java.nio.charset.StandardCharsets;
 import java.util.HashMap;
 import java.util.List;
+import java.util.concurrent.ArrayBlockingQueue;
 import java.util.concurrent.SynchronousQueue;
 import java.util.concurrent.locks.Lock;
 import java.util.concurrent.locks.ReentrantLock;
@@ -36,8 +37,7 @@ public class ChatGptService {
 
     private final CloseableHttpClient client = HttpClients.createDefault();
 
-    private final SynchronousQueue<String> queue = new SynchronousQueue<>();
-
+    private final ArrayBlockingQueue<String> queue = new ArrayBlockingQueue<>(2);
     {
         try {
             queue.put("Bearer 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");