@Override
          public Object load(Object key) {
            loadCount.incrementAndGet();
            return new Object();
          }

          @Override
          public ListenableFuture<Object> reload(Object key, Object oldValue) {
            reloadCount.incrementAndGet();
            return immediateFuture(new Object());
          }

          @Override

                    if (shouldRelease) {
                        session.release();
                        releaseCount.incrementAndGet();
                    } else {
                        session.acquire();
                        acquireCount.incrementAndGet();
                    }

                } catch (Exception e) {
                    // Ignore expected exceptions from over-release

        String resourceId = generateResourceId(resource);
        ResourceHolder holder = new ResourceHolder(resourceId, resource, referenceQueue);

        activeResources.put(resourceId, holder);
        totalAllocated.incrementAndGet();

        log.trace("Registered resource: {} ({})", resourceId, resource.getClass().getSimpleName());

        return resourceId;
    }

    /**
     * Mark a resource as closed
     *

        void recordConnection() {
            connectionsCreated.incrementAndGet();
            lastActivityTime = System.currentTimeMillis();
        }

        void recordSuccess() {
            successCount.incrementAndGet();
            lastActivityTime = System.currentTimeMillis();
        }

        void recordFailure() {
            failureCount.incrementAndGet();
            lastActivityTime = System.currentTimeMillis();

          @Override
          public Object load(Object key) {
            loadCount.incrementAndGet();
            return new Object();
          }

          @Override
          public ListenableFuture<Object> reload(Object key, Object oldValue) {
            reloadCount.incrementAndGet();
            return immediateFuture(new Object());
          }

          @Override

        for (int i = 0; i < numThreads; i++) {
            executor.submit(() -> {
                try {
                    fesenClient.addOnConnectListener(() -> callbackCount.incrementAndGet());
                } finally {
                    latch.countDown();
                }
            });
        }

        latch.await(5, TimeUnit.SECONDS);
        executor.shutdown();

  }

  public void testBasics() {
    AtomicInteger totalCalls = new AtomicInteger();
    Runnable intCounter =
        new Runnable() {
          @Override
          public void run() {
            totalCalls.incrementAndGet();
            // Make sure that no other tasks are scheduled to run while this is running.
            assertFalse(fakePool.hasNext());
          }
        };

    assertFalse(fakePool.hasNext());

    @CanIgnoreReturnValue // Sure, why not?
    @Override
    public Integer load(Integer key) {
      countLoad.incrementAndGet();
      return key;
    }

    @GwtIncompatible // reload
    @Override
    public ListenableFuture<Integer> reload(Integer key, Integer oldValue) {
      countReload.incrementAndGet();
      return immediateFuture(oldValue + 1);
    }

    public int getLoadCount() {

                            // 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);
                            }
                        }

    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() {