com.newrelic.agent.util

Class AgentCollectionFactory

java.lang.Object

com.newrelic.agent.util.AgentCollectionFactory

All Implemented Interfaces:

com.newrelic.agent.bridge.CollectionFactory

public class AgentCollectionFactory
extends java.lang.Object
implements com.newrelic.agent.bridge.CollectionFactory

This is the main implementation of CollectionFactory which is used when the agent is loaded. It delegates to either Caffeine 2.9.3 (Java 8-10) or Caffeine 3.2.3 (Java 11+) based on the detected Java version at runtime.

Uses reflection to load the appropriate factory to avoid class loading issues: - Caffeine 2 uses sun.misc.Unsafe (removed in Java 26+) - Caffeine 3 uses VarHandle (unavailable before Java 11)

A config exists (newrelic.config.collectionfactory.forcev2 or NEW_RELIC_COLLECTIONFACTORY_FORCEV2 env variable) can be used to force the caffeine version 2 factory if version 3 is not usable.

Constructor Summary

Constructors

Constructor and Description
AgentCollectionFactory()

Method Summary

Modifier and Type	Method and Description
<K,V> java.util.function.Function<K,V>	createAccessTimeBasedCache(long ageInSeconds, int initialCapacity, java.util.function.Function<K,V> loader)
<K,V> java.util.function.Function<K,V>	createAccessTimeBasedCacheWithMaxSize(long ageInSeconds, int maxSize, java.util.function.Function<K,V> loader)
<K,V> com.newrelic.agent.bridge.CleanableMap<K,V>	createCacheWithAccessExpirationAndRemovalListener(long age, java.util.concurrent.TimeUnit unit, int initialCapacity, com.newrelic.agent.bridge.CacheRemovalListener<K,V> listener)
<K,V> java.util.Map<K,V>	createCacheWithInitialCapacity(int initialCapacity)
<K,V> java.util.Map<K,V>	createCacheWithWeakKeysAndSize(int maxSize)
<K,V> java.util.Map<K,V>	createCacheWithWeakKeysInitialCapacityAndSize(int initialCapacity, int maxSize)
<K,V> com.newrelic.agent.bridge.CleanableMap<K,V>	createCacheWithWriteExpirationAndRemovalListener(long age, java.util.concurrent.TimeUnit unit, int initialCapacity, com.newrelic.agent.bridge.CacheRemovalListener<K,V> listener)
<K,V> java.util.Map<K,V>	createConcurrentAccessTimeBasedEvictionMap(long ageInSeconds, int initialCapacity)
<K,V> java.util.Map<K,V>	createConcurrentTimeBasedEvictionMap(long ageInSeconds)
<K,V> java.util.Map<K,V>	createConcurrentWeakKeyedMap()
<K,V> java.util.function.Function<K,V>	createLoadingCache(java.util.function.Function<K,V> loader)
<K,V> java.util.Map<K,V>	createWeakKeyedCacheWithInitialCapacity(int initialCapacity)
<K,V> java.util.function.Function<K,V>	createWeakKeyedLoadingCacheWithInitialCapacity(int initialCapacity, java.util.function.Function<K,V> loader)
<K,V> java.util.function.Function<K,V>	memorize(java.util.function.Function<K,V> loader, int maxSize)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

AgentCollectionFactory

public AgentCollectionFactory()

Method Detail

createConcurrentWeakKeyedMap

public <K,V> java.util.Map<K,V> createConcurrentWeakKeyedMap()

Specified by:

createConcurrentWeakKeyedMap in interface com.newrelic.agent.bridge.CollectionFactory

createConcurrentTimeBasedEvictionMap

public <K,V> java.util.Map<K,V> createConcurrentTimeBasedEvictionMap(long ageInSeconds)

Specified by:

createConcurrentTimeBasedEvictionMap in interface com.newrelic.agent.bridge.CollectionFactory

createConcurrentAccessTimeBasedEvictionMap

public <K,V> java.util.Map<K,V> createConcurrentAccessTimeBasedEvictionMap(long ageInSeconds,
                                                                           int initialCapacity)

Specified by:

createConcurrentAccessTimeBasedEvictionMap in interface com.newrelic.agent.bridge.CollectionFactory

memorize

public <K,V> java.util.function.Function<K,V> memorize(java.util.function.Function<K,V> loader,
                                                       int maxSize)

Specified by:

memorize in interface com.newrelic.agent.bridge.CollectionFactory

createAccessTimeBasedCache

public <K,V> java.util.function.Function<K,V> createAccessTimeBasedCache(long ageInSeconds,
                                                                         int initialCapacity,
                                                                         java.util.function.Function<K,V> loader)

Specified by:

createAccessTimeBasedCache in interface com.newrelic.agent.bridge.CollectionFactory

createAccessTimeBasedCacheWithMaxSize

public <K,V> java.util.function.Function<K,V> createAccessTimeBasedCacheWithMaxSize(long ageInSeconds,
                                                                                    int maxSize,
                                                                                    java.util.function.Function<K,V> loader)

Specified by:

createAccessTimeBasedCacheWithMaxSize in interface com.newrelic.agent.bridge.CollectionFactory

createLoadingCache

public <K,V> java.util.function.Function<K,V> createLoadingCache(java.util.function.Function<K,V> loader)

Specified by:

createLoadingCache in interface com.newrelic.agent.bridge.CollectionFactory

createCacheWithWeakKeysAndSize

public <K,V> java.util.Map<K,V> createCacheWithWeakKeysAndSize(int maxSize)

Specified by:

createCacheWithWeakKeysAndSize in interface com.newrelic.agent.bridge.CollectionFactory

createWeakKeyedCacheWithInitialCapacity

public <K,V> java.util.Map<K,V> createWeakKeyedCacheWithInitialCapacity(int initialCapacity)

Specified by:

createWeakKeyedCacheWithInitialCapacity in interface com.newrelic.agent.bridge.CollectionFactory

createCacheWithWeakKeysInitialCapacityAndSize

public <K,V> java.util.Map<K,V> createCacheWithWeakKeysInitialCapacityAndSize(int initialCapacity,
                                                                              int maxSize)

Specified by:

createCacheWithWeakKeysInitialCapacityAndSize in interface com.newrelic.agent.bridge.CollectionFactory

createCacheWithInitialCapacity

public <K,V> java.util.Map<K,V> createCacheWithInitialCapacity(int initialCapacity)

Specified by:

createCacheWithInitialCapacity in interface com.newrelic.agent.bridge.CollectionFactory

createWeakKeyedLoadingCacheWithInitialCapacity

public <K,V> java.util.function.Function<K,V> createWeakKeyedLoadingCacheWithInitialCapacity(int initialCapacity,
                                                                                             java.util.function.Function<K,V> loader)

Specified by:

createWeakKeyedLoadingCacheWithInitialCapacity in interface com.newrelic.agent.bridge.CollectionFactory

createCacheWithWriteExpirationAndRemovalListener

public <K,V> com.newrelic.agent.bridge.CleanableMap<K,V> createCacheWithWriteExpirationAndRemovalListener(long age,
                                                                                                          java.util.concurrent.TimeUnit unit,
                                                                                                          int initialCapacity,
                                                                                                          com.newrelic.agent.bridge.CacheRemovalListener<K,V> listener)

Specified by:

createCacheWithWriteExpirationAndRemovalListener in interface com.newrelic.agent.bridge.CollectionFactory

createCacheWithAccessExpirationAndRemovalListener

public <K,V> com.newrelic.agent.bridge.CleanableMap<K,V> createCacheWithAccessExpirationAndRemovalListener(long age,
                                                                                                           java.util.concurrent.TimeUnit unit,
                                                                                                           int initialCapacity,
                                                                                                           com.newrelic.agent.bridge.CacheRemovalListener<K,V> listener)

Specified by:

createCacheWithAccessExpirationAndRemovalListener in interface com.newrelic.agent.bridge.CollectionFactory