Package io.reactivex.rxjava3.internal.schedulers

Class RxThreadFactory

java.lang.Object

java.lang.Number

java.util.concurrent.atomic.AtomicLong

io.reactivex.rxjava3.internal.schedulers.RxThreadFactory

All Implemented Interfaces:

Serializable, ThreadFactory

public final class RxThreadFactory
extends AtomicLong
implements ThreadFactory

A ThreadFactory that counts how many threads have been created and given a prefix, sets the created Thread's name to prefix-count.

See Also:

• Serialized Form

Constructor Summary

Constructors

Constructor	Description
RxThreadFactory(String prefix)
RxThreadFactory(String prefix, int priority)
RxThreadFactory(String prefix, int priority, boolean nonBlocking)

Method Summary

Modifier and Type	Method	Description
Thread	newThread(@NonNull Runnable r)
String	toString()

Methods inherited from class java.util.concurrent.atomic.AtomicLong

accumulateAndGet, addAndGet, compareAndExchange, compareAndExchangeAcquire, compareAndExchangeRelease, compareAndSet, decrementAndGet, doubleValue, floatValue, get, getAcquire, getAndAccumulate, getAndAdd, getAndDecrement, getAndIncrement, getAndSet, getAndUpdate, getOpaque, getPlain, incrementAndGet, intValue, lazySet, longValue, set, setOpaque, setPlain, setRelease, updateAndGet, weakCompareAndSet, weakCompareAndSetAcquire, weakCompareAndSetPlain, weakCompareAndSetRelease, weakCompareAndSetVolatile

Methods inherited from class java.lang.Number

byteValue, shortValue

Methods inherited from class java.lang.Object

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

Constructor Details

RxThreadFactory

public RxThreadFactory(String prefix)

RxThreadFactory

public RxThreadFactory(String prefix,
 int priority)

RxThreadFactory

public RxThreadFactory(String prefix,
 int priority,
 boolean nonBlocking)

Method Details

newThread

public Thread newThread(@NonNull
 @NonNull Runnable r)

Specified by:

newThread in interface ThreadFactory

toString

public String toString()

Overrides:

toString in class AtomicLong