Class SchedulerPoolFactory
- java.lang.Object
-
- io.reactivex.rxjava3.internal.schedulers.SchedulerPoolFactory
-
public final class SchedulerPoolFactory extends java.lang.Object
Manages the creating of ScheduledExecutorServices and sets up purging.
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description (package private) static class
SchedulerPoolFactory.SystemPropertyAccessor
-
Field Summary
Fields Modifier and Type Field Description static boolean
PURGE_ENABLED
(package private) static java.lang.String
PURGE_ENABLED_KEY
-
Constructor Summary
Constructors Modifier Constructor Description private
SchedulerPoolFactory()
Utility class.
-
Method Summary
All Methods Static Methods Concrete Methods Modifier and Type Method Description static java.util.concurrent.ScheduledExecutorService
create(java.util.concurrent.ThreadFactory factory)
Creates a ScheduledExecutorService with the given factory.(package private) static boolean
getBooleanProperty(boolean enabled, java.lang.String key, boolean defaultNotFound, boolean defaultNotEnabled, Function<java.lang.String,java.lang.String> propertyAccessor)
-
-
-
Field Detail
-
PURGE_ENABLED_KEY
static final java.lang.String PURGE_ENABLED_KEY
- See Also:
- Constant Field Values
-
PURGE_ENABLED
public static final boolean PURGE_ENABLED
-
-
Method Detail
-
getBooleanProperty
static boolean getBooleanProperty(boolean enabled, java.lang.String key, boolean defaultNotFound, boolean defaultNotEnabled, Function<java.lang.String,java.lang.String> propertyAccessor)
-
create
public static java.util.concurrent.ScheduledExecutorService create(java.util.concurrent.ThreadFactory factory)
Creates a ScheduledExecutorService with the given factory.- Parameters:
factory
- the thread factory- Returns:
- the ScheduledExecutorService
-
-