Top Description Inners Fields Constructors Methods

reactor.core.scheduler

pack-priv Class ReactorThreadFactory

Class Inheritance

extends Object
implements ThreadFactory, Supplier<String>, UncaughtExceptionHandler

java.lang.Object
reactor.core.scheduler.ReactorThreadFactory

All Implemented Interfaces

java.lang.Thread.UncaughtExceptionHandler, java.util.function.Supplier, java.util.concurrent.ThreadFactory

Imports

java.util.concurrent.ThreadFactory, java.util.concurrent.atomic.AtomicLong, java.util.function.BiConsumer, .Supplier, reactor.util.annotation.NonNull, .Nullable

The standard Reactor Thread factories to be used by Scheduler, creating Thread with a prefix (which can be retrieved with the get() method).

Author: Simon Baslé

Nested and Inner Type Summary

Modifier and Type	Class and Description
pack-priv static class	ReactorThreadFactory.NonBlockingThread

Field Summary

Modifier and Type	Field and Description
private final AtomicLong	counterReference
private final boolean	daemon
private final String	name
private final boolean	rejectBlocking
private final BiConsumer<Thread, Throwable>	uncaughtExceptionHandler

Constructor Summary

Access	Constructor and Description
pack-priv	ReactorThreadFactory(String name, AtomicLong counterReference, boolean daemon, boolean rejectBlocking, BiConsumer<Thread, Throwable> uncaughtExceptionHandler)

Method Summary

Modifier and Type	Method and Description
public final String	Returns: the thread name prefix get() Implements java.util.function.Supplier.get. Get the prefix used for new `Threads` created by this `ThreadFactory`.
public final Thread	newThread(Runnable a runnable to be executed by new thread instance runnable) Implements java.util.concurrent.ThreadFactory.newThread. Constructs a new unstarted `Thread` to run the given runnable.
public void	uncaughtException(Thread the thread t, Throwable the exception e) Implements java.lang.Thread.UncaughtExceptionHandler.uncaughtException. Method invoked when the given thread terminates due to the given uncaught exception.

Inherited from java.lang.Object:: clone equals finalize getClass hashCode notify notifyAll toString wait wait wait

Field Detail

counterReference	back to summary
private final AtomicLong counterReference

daemon	back to summary
private final boolean daemon

name	back to summary
private final String name

rejectBlocking	back to summary
private final boolean rejectBlocking

uncaughtExceptionHandler	back to summary
private final BiConsumer<Thread, Throwable> uncaughtExceptionHandler Annotations @Nullable

Constructor Detail

ReactorThreadFactory	back to summary
pack-priv ReactorThreadFactory(String name, AtomicLong counterReference, boolean daemon, boolean rejectBlocking, BiConsumer<Thread, Throwable> uncaughtExceptionHandler)

Method Detail

get back to summary

get	back to summary
public final String get() Implements java.util.function.Supplier.get. Get the prefix used for new `Threads` created by this `ThreadFactory`. The factory can also be seen as a `Supplier<String>`. Returns:String the thread name prefix Annotations @Override

public final String get()

Implements java.util.function.Supplier.get.

Get the prefix used for new Threads created by this ThreadFactory. The factory can also be seen as a Supplier<String>.

Returns:String

the thread name prefix

Annotations

@Override

newThread back to summary

newThread	back to summary
public final Thread newThread(Runnable runnable) Implements java.util.concurrent.ThreadFactory.newThread. Doc from java.util.concurrent.ThreadFactory.newThread. Constructs a new unstarted `Thread` to run the given runnable. Parameters runnable: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

public final Thread newThread(Runnable runnable)

Implements java.util.concurrent.ThreadFactory.newThread.

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

Constructs a new unstarted Thread to run the given runnable.

Parameters

runnable: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

uncaughtException	back to summary
public void uncaughtException(Thread t, Throwable e) Implements java.lang.Thread.UncaughtExceptionHandler.uncaughtException. Doc from java.lang.Thread.UncaughtExceptionHandler.uncaughtException. Method invoked when the given thread terminates due to the given uncaught exception. Any exception thrown by this method will be ignored by the Java Virtual Machine. Parameters t:Thread the thread e:Throwable the exception Annotations @Override

uncaughtException

back to summary

public void uncaughtException(Thread t, Throwable e)

Implements java.lang.Thread.UncaughtExceptionHandler.uncaughtException.

Doc from java.lang.Thread.UncaughtExceptionHandler.uncaughtException.

Method invoked when the given thread terminates due to the given uncaught exception.

Any exception thrown by this method will be ignored by the Java Virtual Machine.

Parameters