assertEquals(3, customCb.getFailureCount(), "Failure count should match threshold");
        } finally {
            customCb.close();
        }
    }

    @Test
    public void testConcurrentOperations() throws Exception {
        int threadCount = 10;
        int operationsPerThread = 100;
        CountDownLatch latch = new CountDownLatch(threadCount);