Top Fields Constructors Methods
reactor.core.scheduler

pack-priv final Class SchedulerMetricDecorator

extends Object
implements BiFunction<Scheduler, ScheduledExecutorService, ScheduledExecutorService>, Disposable
Class Inheritance
All Implemented Interfaces
reactor.core.Disposable, java.util.function.BiFunction
Annotations
@Deprecated
Imports
java.util.HashMap, .List, .Map, .WeakHashMap, java.util.concurrent.ScheduledExecutorService, java.util.concurrent.atomic.AtomicInteger, java.util.function.BiFunction, io.micrometer.core.instrument.MeterRegistry, io.micrometer.core.instrument.Tag, io.micrometer.core.instrument.binder.jvm.ExecutorServiceMetrics, io.micrometer.core.instrument.search.Search, reactor.core.Disposable, .Scannable, .Scannable.Attr, reactor.util.Metrics

Deprecated

Field Summary

Modifier and TypeField and Description
pack-priv final WeakHashMap<Scheduler, AtomicInteger>
executorDifferentiator

pack-priv static final String
METRICS_DECORATOR_KEY

pack-priv final io.micrometer.core.instrument.MeterRegistry
registry

pack-priv final Map<String, AtomicInteger>
schedulerDifferentiator

pack-priv final WeakHashMap<Scheduler, String>
seenSchedulers

pack-priv static final String
TAG_SCHEDULER_ID

Constructor Summary

AccessConstructor and Description
pack-priv
SchedulerMetricDecorator()

Method Summary

Modifier and TypeMethod and Description
public synchronized ScheduledExecutorService
apply(Scheduler
the first function argument
scheduler, ScheduledExecutorService
the second function argument
service)

Implements java.util.function.BiFunction.apply.

Applies this function to the given arguments.
public void
dispose()

Implements reactor.core.Disposable.dispose.

Cancel or dispose the underlying task or resource.
Inherited from java.lang.Object:
cloneequalsfinalizegetClasshashCodenotifynotifyAlltoStringwaitwaitwait

Field Detail

executorDifferentiatorback to summary
pack-priv final WeakHashMap<Scheduler, AtomicInteger> executorDifferentiator
METRICS_DECORATOR_KEYback to summary
pack-priv static final String METRICS_DECORATOR_KEY
registryback to summary
pack-priv final io.micrometer.core.instrument.MeterRegistry registry
schedulerDifferentiatorback to summary
pack-priv final Map<String, AtomicInteger> schedulerDifferentiator
seenSchedulersback to summary
pack-priv final WeakHashMap<Scheduler, String> seenSchedulers
TAG_SCHEDULER_IDback to summary
pack-priv static final String TAG_SCHEDULER_ID

Constructor Detail

SchedulerMetricDecoratorback to summary
pack-priv SchedulerMetricDecorator()

Method Detail

applyback to summary
public synchronized ScheduledExecutorService apply(Scheduler scheduler, ScheduledExecutorService service)

Implements java.util.function.BiFunction.apply.

Doc from java.util.function.BiFunction.apply.

Applies this function to the given arguments.

Parameters
scheduler:Scheduler

the first function argument

service:ScheduledExecutorService

the second function argument

Returns:ScheduledExecutorService

the function result

Annotations
@Override
disposeback to summary
public void dispose()

Implements reactor.core.Disposable.dispose.

Doc from reactor.core.Disposable.dispose.

Cancel or dispose the underlying task or resource.

Implementations are required to make this method idempotent.

Annotations
@Override