"""
This module provides a thread pool executor for managing concurrent tasks.
It is shared between the producer and consumer logic, so that it can be
reused during the container lifecycle.
"""

from ..config import MAX_THREADS
from concurrent.futures import ThreadPoolExecutor

executor = ThreadPoolExecutor(max_workers=MAX_THREADS)