request_queue/queue_manager.py

import threading
from queue import Queue

class RequestQueue:
    def __init__(self, maxsize=10):
        self.queue = Queue(maxsize=maxsize)
        self.lock = threading.Lock()

    def add_request(self, request):
        with self.lock:
            self.queue.put(request)

    def get_request(self):
        with self.lock:
            return self.queue.get()