Top Description Inners Fields Constructors Methods
io.reactivex.internal.schedulers

public final Class RxThreadFactory

extends AtomicLong
implements ThreadFactory
Class Inheritance
All Implemented Interfaces
java.util.concurrent.ThreadFactory
Imports
java.util.concurrent.ThreadFactory, java.util.concurrent.atomic.AtomicLong

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

Nested and Inner Type Summary

Modifier and TypeClass and Description
pack-priv static class

Field Summary

Modifier and TypeField and Description
pack-priv final boolean
pack-priv final String
pack-priv final int
private static final long

Constructor Summary

AccessConstructor and Description
public
public
RxThreadFactory(String prefix, int priority)

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

Method Summary

Modifier and TypeMethod and Description
public Thread
newThread(Runnable
a runnable to be executed by new thread instance
r
)

Implements java.util.concurrent.ThreadFactory.newThread.

Constructs a new unstarted Thread to run the given runnable.
public String
toString()

Overrides java.util.concurrent.atomic.AtomicLong.toString.

Returns the String representation of the current value.
Inherited from java.util.concurrent.atomic.AtomicLong:
accumulateAndGetaddAndGetcompareAndExchangecompareAndExchangeAcquirecompareAndExchangeReleasecompareAndSetdecrementAndGetdoubleValuefloatValuegetgetAcquiregetAndAccumulategetAndAddgetAndDecrementgetAndIncrementgetAndSetgetAndUpdategetOpaquegetPlainincrementAndGetintValuelazySetlongValuesetsetOpaquesetPlainsetReleaseupdateAndGetweakCompareAndSetweakCompareAndSetAcquireweakCompareAndSetPlainweakCompareAndSetReleaseweakCompareAndSetVolatile

Field Detail

nonBlockingback to summary
pack-priv final boolean nonBlocking
prefixback to summary
pack-priv final String prefix
priorityback to summary
pack-priv final int priority
serialVersionUIDback to summary
private static final long serialVersionUID

Hides java.util.concurrent.atomic.AtomicLong.serialVersionUID.

Constructor Detail

RxThreadFactoryback to summary
public RxThreadFactory(String prefix)
RxThreadFactoryback to summary
public RxThreadFactory(String prefix, int priority)
RxThreadFactoryback to summary
public RxThreadFactory(String prefix, int priority, boolean nonBlocking)

Method Detail

newThreadback to summary
public Thread newThread(Runnable r)

Implements java.util.concurrent.ThreadFactory.newThread.

Doc from java.util.concurrent.ThreadFactory.newThread.

Constructs a new unstarted Thread to run the given runnable.

Parameters
r:Runnable

a runnable to be executed by new thread instance

Returns:Thread

constructed thread, or null if the request to create a thread is rejected

Annotations
@Override
toStringback to summary
public String toString()

Overrides java.util.concurrent.atomic.AtomicLong.toString.

Doc from java.util.concurrent.atomic.AtomicLong.toString.

Returns the String representation of the current value.

Returns:String

the String representation of the current value

Annotations
@Override
io.reactivex.internal.schedulers back to summary

pack-priv final Class RxThreadFactory.RxCustomThread

extends Thread
implements NonBlockingThread
Class Inheritance
All Implemented Interfaces
io.reactivex.internal.schedulers.NonBlockingThread

Field Summary

Inherited from java.lang.Thread:
MAX_PRIORITYMIN_PRIORITYNORM_PRIORITY

Constructor Summary

AccessConstructor and Description
pack-priv

Method Summary

Inherited from java.lang.Thread:
activeCountcheckAccessclonecountStackFramescurrentThreaddumpStackenumerategetAllStackTracesgetContextClassLoadergetDefaultUncaughtExceptionHandlergetIdgetNamegetPrioritygetStackTracegetStategetThreadGroupgetUncaughtExceptionHandlerholdsLockinterruptinterruptedisAliveisDaemonisInterruptedisVirtualjoinjoinjoinjoinofPlatformofVirtualonSpinWaitresumerunsetContextClassLoadersetDaemonsetDefaultUncaughtExceptionHandlersetNamesetPrioritysetUncaughtExceptionHandlersleepsleepsleepstartstartVirtualThreadstopsuspendthreadIdtoStringyield

Constructor Detail

RxCustomThreadback to summary
pack-priv RxCustomThread(Runnable run, String name)