Skip to content

Commit 8acd24a

Browse files
committed
feat: make meter cleaning thread number configurable
1 parent c7cc959 commit 8acd24a

File tree

1 file changed

+4
-3
lines changed

1 file changed

+4
-3
lines changed

micrometer-support/src/main/java/io/javaoperatorsdk/operator/monitoring/micrometer/MicrometerMetrics.java

Lines changed: 4 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -32,16 +32,17 @@ public class MicrometerMetrics implements Metrics {
3232
private final MeterRegistry registry;
3333
private final Map<String, AtomicInteger> gauges = new ConcurrentHashMap<>();
3434
private final Map<ResourceID, Set<Meter.Id>> metersPerResource = new ConcurrentHashMap<>();
35-
private final ScheduledExecutorService metersCleaner = Executors.newScheduledThreadPool(10);
35+
private final ScheduledExecutorService metersCleaner;
3636
private final int cleanUpDelayInSeconds;
3737

3838
public MicrometerMetrics(MeterRegistry registry) {
39-
this(registry, 300);
39+
this(registry, 300, Runtime.getRuntime().availableProcessors());
4040
}
4141

42-
public MicrometerMetrics(MeterRegistry registry, int cleanUpDelayInSeconds) {
42+
public MicrometerMetrics(MeterRegistry registry, int cleanUpDelayInSeconds, int cleaningThreadsNumber) {
4343
this.registry = registry;
4444
this.cleanUpDelayInSeconds = cleanUpDelayInSeconds;
45+
this.metersCleaner = Executors.newScheduledThreadPool(cleaningThreadsNumber);
4546
}
4647

4748
@Override

0 commit comments

Comments
 (0)