public int weigh(String key, CompletableFuture<PreparsedDocumentEntry> value) {
  // Estimate memory usage including CompletableFuture overhead
  long keyWeight = key.length() * 2; // UTF-16 encoding
  long futureOverhead = 200; // Estimated CompletableFuture overhead
  long documentOverhead = 500; // Estimated PreparsedDocumentEntry overhead

  long totalWeight = keyWeight + futureOverhead + documentOverhead;

  // Bounds checking to prevent single entries from dominating cache
  return (int) Math.min(totalWeight, maxSingleEntryWeight);
}

if (cause == RemovalCause.EXPIRED) {
  // Session is timing out, stopping it by sending a DELETE
  LOG.log(Level.INFO, () -> String.format("Session id %s timed out, stopping...", id));
  span.setStatus(Status.CANCELLED);
  span.addEvent(String.format("Stopping the the timed session %s", id), attributeMap);
} else {
  LOG.log(Level.INFO, () -> String.format("Session id %s is stopping on demand...", id));
  span.addEvent(String.format("Stopping the session %s on demand", id), attributeMap);
}
if (cause == RemovalCause.EXPIRED) {

public void close() {
  // Cancel pending CompletableFutures
  cache
      .asMap()
      .values()
      .forEach(
          future -> {
            if (!future.isDone()) {
              future.cancel(true);
            }
          });

  // Invalidate and clean cache
  cache.invalidateAll();
  cache.cleanUp();
}