// Test connection pool operations without actually connecting
                            boolean contains = pool.contains(null); // Should handle gracefully
                            successCount.incrementAndGet();
                        } catch (Exception e) {
                            synchronized (exceptions) {
                                exceptions.add(e);
                            }
                        }

                // Do nothing
            }

            @Override
            public void stop() {
                stopCallCount.incrementAndGet();
            }
        };

        // Execute stop multiple times
        dataStore.stop();
        dataStore.stop();
        dataStore.stop();

        assertEquals(3, stopCallCount.get());

    assertEquals(0L, map.get(key));
    assertFalse(map.containsKey(key));

    assertEquals(1L, map.incrementAndGet(key));
    assertEquals(1L, map.get(key));

    assertEquals(0L, map.decrementAndGet(key));
    assertEquals(0L, map.get(key));
    assertTrue(map.containsKey(key));

    assertEquals(1L, map.incrementAndGet(key));
    assertEquals(1L, map.get(key));
  }

  public void testGetAndIncrement() {

                            // Some successes
                            breaker.call(() -> "success");
                            successCount.incrementAndGet();
                        }
                    } catch (Exception e) {
                        failureCount.incrementAndGet();
                    }
                }
            });
        }

        // Start all threads
        for (Thread t : threads) {

                                blockedAttempts.incrementAndGet();
                                break; // Stop trying if account is locked
                            }

                            if (!allowed) {
                                // Rate limited but not locked out
                                blockedAttempts.incrementAndGet();
                                continue;
                            }

        requestsSent.incrementAndGet();
    }

    /**
     * Increment requests received counter
     */
    public void incrementRequestsReceived() {
        requestsReceived.incrementAndGet();
    }

    /**
     * Increment error counter
     */
    public void incrementErrors() {
        errors.incrementAndGet();
    }

    /**

                            for (int j = 0; j < searchersPerThread; j++) {
                                processor.register(new TestSearcher(10 + threadId * 10 + j));
                                registeredCount.incrementAndGet();
                            }
                        } catch (InterruptedException e) {
                            Thread.currentThread().interrupt();
                        } finally {

                        successCount.incrementAndGet();
                    } catch (RuntimeException e) {
                        failureCount.incrementAndGet();
                    } catch (Exception e) {
                        // Other exceptions also count as failures in this context
                        failureCount.incrementAndGet();
                    }
                });
            }

                                }
                                return "success";
                            });
                            successCount.incrementAndGet();
                        } catch (Exception e) {
                            failureCount.incrementAndGet();
                        }
                    }
                } finally {
                    latch.countDown();
                }
            });

    
    public void recordRegistration() { registrationsActive.incrementAndGet(); }
    public void recordUnregistration() { registrationsActive.decrementAndGet(); }
    public void recordNotification() { notificationsReceived.incrementAndGet(); }
    public void recordFailover() { failoverEvents.incrementAndGet(); }
    public void recordHeartbeat() { heartbeatsSent.incrementAndGet(); }