(queueSize.get() * 100.0 / MAX_BUFFERS));
    }

    /**
     * Clear all cached buffers (for testing or cleanup)
     */
    public static void clearCache() {
        bufferQueue.clear();
        queueSize.set(0);
    }

        Mockito.when(mockConfig.getSessionLimit()).thenReturn(10);

        // Clear buffer cache for consistent test results
        BufferCache.clearCache();
    }

    /**
     * Test connection pool scalability with concurrent access
     */
    @Test
    public void testConnectionPoolConcurrentPerformance() throws Exception {

    // Mock PopularWordHelper implementation
    private class MockPopularWordHelper extends PopularWordHelper {
        private boolean cacheCleared = false;

        @Override
        public void clearCache() {
            cacheCleared = true;
        }

        public boolean isCacheCleared() {
            return cacheCleared;
        }
    }

    // Mock JobExecutor implementation