reactor.core.scheduler

类 SchedulersTest

java.lang.Object

reactor.core.scheduler.SchedulersTest

public class SchedulersTest
extends java.lang.Object

构造器概要

构造器

构造器和说明
SchedulersTest()

方法概要

限定符和类型	方法和说明
void	boundedElasticSchedulerDefaultBlockingOk()
void	boundedElasticSchedulerThreadCheck()
void	executorThreadCheck()
void	executorThreadCheck2()
void	handleErrorWithJvmFatalForwardsToUncaughtHandlerFusedCallable()
void	handleErrorWithJvmFatalForwardsToUncaughtHandlerFusedInnerCallable()
void	handleErrorWithJvmFatalForwardsToUncaughtHandlerSyncCallable()
void	handleErrorWithJvmFatalForwardsToUncaughtHandlerSyncInnerCallable()
void	immediateTaskIsExecuted()
void	isInNonBlockingThreadFalse()
void	isInNonBlockingThreadTrue()
void	isNonBlockingThreadInstanceOf()
void	parallelSchedulerDefaultNonBlocking()
void	parallelSchedulerThreadCheck()
void	pingPongParallelCall()
void	recursiveParallelCall()
void	resetSchedulers()
void	restartBoundedElastic()
void	restartParallel()
void	restartSingle()
void	scanExecutorCapacity()
void	scanSupportBuffered()
void	scheduleInstantTaskTest()
void	scheduleInstantTaskWithDelayTest()
void	schedulerDecoratorAddsOnceIfSameKey()
void	schedulerDecoratorAddsSameIfDifferentKeys()
void	schedulerDecoratorDisposedWhenRemoved()
void	schedulerDecoratorEmptyDecorators()
void	schedulerDecoratorIsAdditive()
void	schedulerDecoratorIsReplaceable()
void	schedulerDecoratorRemovesKnown()
void	schedulerDecoratorRemoveUnknownIgnored()
void	sharedSingleCheck()
void	shutdownNowClosesAllCachedSchedulers()
void	singleSchedulerDefaultNonBlocking()
void	singleSchedulerPipelining()
void	singleSchedulerThreadCheck()
void	testCachedSchedulerDelegates()
void	testDefaultMethods()
void	testDirectSchedulePeriodicallyCancelsSchedulerTask()
void	testDirectScheduleZeroPeriodicallyCancelsSchedulerTask()
void	testDispatch()
void	testDisposeGracefully()
void	testOverride()
void	testRejectingExecutorServiceScheduler()
void	testRejectingParallelScheduler()
void	testRejectingSingleScheduler()
void	testShutdownOldOnSetFactory()
void	testUncaughtHookCalledWhenCommonException()
void	testUncaughtHookCalledWhenOnErrorNotImplemented()
void	testUncaughtHooksCalledWhenThreadDeath()
void	testWorkerSchedulePeriodicallyCancelsSchedulerTask()
void	testWorkerScheduleRejectedWithDisposedParent()
void	testWorkerScheduleSupportZeroPeriod()
void	testWorkerScheduleSupportZeroPeriodWithDelayPeriod()

从类继承的方法 java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

构造器详细资料

SchedulersTest

public SchedulersTest()

方法详细资料

resetSchedulers

@AfterEach
public void resetSchedulers()

schedulerDecoratorIsAdditive

@Test
public void schedulerDecoratorIsAdditive()
                                         throws java.lang.InterruptedException

抛出:

java.lang.InterruptedException

schedulerDecoratorIsReplaceable

@Test
public void schedulerDecoratorIsReplaceable()
                                            throws java.lang.InterruptedException

抛出:

java.lang.InterruptedException

schedulerDecoratorAddsSameIfDifferentKeys

@Test
public void schedulerDecoratorAddsSameIfDifferentKeys()

schedulerDecoratorAddsOnceIfSameKey

@Test
public void schedulerDecoratorAddsOnceIfSameKey()

schedulerDecoratorDisposedWhenRemoved

@Test
public void schedulerDecoratorDisposedWhenRemoved()

schedulerDecoratorEmptyDecorators

@Test
public void schedulerDecoratorEmptyDecorators()

schedulerDecoratorRemovesKnown

@Test
public void schedulerDecoratorRemovesKnown()

schedulerDecoratorRemoveUnknownIgnored

@Test
public void schedulerDecoratorRemoveUnknownIgnored()

parallelSchedulerDefaultNonBlocking

@Test
public void parallelSchedulerDefaultNonBlocking()
                                                throws java.lang.InterruptedException

抛出:

java.lang.InterruptedException

singleSchedulerDefaultNonBlocking

@Test
public void singleSchedulerDefaultNonBlocking()
                                              throws java.lang.InterruptedException

抛出:

java.lang.InterruptedException

boundedElasticSchedulerDefaultBlockingOk

@Test
public void boundedElasticSchedulerDefaultBlockingOk()
                                                     throws java.lang.InterruptedException

抛出:

java.lang.InterruptedException

isInNonBlockingThreadFalse

@Test
public void isInNonBlockingThreadFalse()

isNonBlockingThreadInstanceOf

@Test
public void isNonBlockingThreadInstanceOf()

isInNonBlockingThreadTrue

@Test
public void isInNonBlockingThreadTrue()

handleErrorWithJvmFatalForwardsToUncaughtHandlerFusedCallable

@Test
public void handleErrorWithJvmFatalForwardsToUncaughtHandlerFusedCallable()

handleErrorWithJvmFatalForwardsToUncaughtHandlerSyncCallable

@Test
public void handleErrorWithJvmFatalForwardsToUncaughtHandlerSyncCallable()

handleErrorWithJvmFatalForwardsToUncaughtHandlerSyncInnerCallable

@Test
public void handleErrorWithJvmFatalForwardsToUncaughtHandlerSyncInnerCallable()

handleErrorWithJvmFatalForwardsToUncaughtHandlerFusedInnerCallable

@Test
public void handleErrorWithJvmFatalForwardsToUncaughtHandlerFusedInnerCallable()

testOverride

@Test
public void testOverride()

testShutdownOldOnSetFactory

@Test
public void testShutdownOldOnSetFactory()

shutdownNowClosesAllCachedSchedulers

@Test
public void shutdownNowClosesAllCachedSchedulers()

testUncaughtHookCalledWhenOnErrorNotImplemented

@Test
public void testUncaughtHookCalledWhenOnErrorNotImplemented()

testUncaughtHookCalledWhenCommonException

@Test
public void testUncaughtHookCalledWhenCommonException()

testUncaughtHooksCalledWhenThreadDeath

@Test
public void testUncaughtHooksCalledWhenThreadDeath()

testRejectingSingleScheduler

@Test
 @Tag(value="slow")
public void testRejectingSingleScheduler()

testRejectingParallelScheduler

@Test
 @Tag(value="slow")
public void testRejectingParallelScheduler()

testRejectingExecutorServiceScheduler

@Test
 @Tag(value="slow")
public void testRejectingExecutorServiceScheduler()

testDispatch

@Test
public void testDispatch()
                         throws java.lang.Exception

抛出:

java.lang.Exception

immediateTaskIsExecuted

@Test
public void immediateTaskIsExecuted()
                                    throws java.lang.Exception

抛出:

java.lang.Exception

singleSchedulerPipelining

@Test
public void singleSchedulerPipelining()
                                      throws java.lang.Exception

抛出:

java.lang.Exception

testCachedSchedulerDelegates

@Test
public void testCachedSchedulerDelegates()

parallelSchedulerThreadCheck

@Test
 @Timeout(value=5L)
public void parallelSchedulerThreadCheck()
                                                              throws java.lang.Exception

抛出:

java.lang.Exception

singleSchedulerThreadCheck

@Test
 @Timeout(value=5L)
public void singleSchedulerThreadCheck()
                                                            throws java.lang.Exception

抛出:

java.lang.Exception

boundedElasticSchedulerThreadCheck

@Test
 @Timeout(value=5L)
public void boundedElasticSchedulerThreadCheck()
                                                                    throws java.lang.Exception

抛出:

java.lang.Exception

executorThreadCheck

@Test
 @Timeout(value=5L)
public void executorThreadCheck()
                                                     throws java.lang.Exception

抛出:

java.lang.Exception

executorThreadCheck2

@Test
 @Timeout(value=5L)
public void executorThreadCheck2()
                                                      throws java.lang.Exception

抛出:

java.lang.Exception

sharedSingleCheck

@Test
 @Timeout(value=5L)
public void sharedSingleCheck()
                                                   throws java.lang.Exception

抛出:

java.lang.Exception

recursiveParallelCall

@Test
public void recursiveParallelCall()
                                  throws java.lang.Exception

抛出:

java.lang.Exception

pingPongParallelCall

@Test
public void pingPongParallelCall()
                                 throws java.lang.Exception

抛出:

java.lang.Exception

restartParallel

@Test
public void restartParallel()

restartBoundedElastic

@Test
public void restartBoundedElastic()

restartSingle

@Test
public void restartSingle()

testDefaultMethods

@Test
public void testDefaultMethods()

testDisposeGracefully

@Test
public void testDisposeGracefully()

scanExecutorCapacity

@Test
public void scanExecutorCapacity()

scanSupportBuffered

@Test
public void scanSupportBuffered()
                                throws java.lang.InterruptedException

抛出:

java.lang.InterruptedException

testDirectSchedulePeriodicallyCancelsSchedulerTask

@Test
public void testDirectSchedulePeriodicallyCancelsSchedulerTask()
                                                               throws java.lang.Exception

抛出:

java.lang.Exception

testDirectScheduleZeroPeriodicallyCancelsSchedulerTask

@Test
public void testDirectScheduleZeroPeriodicallyCancelsSchedulerTask()
                                                                   throws java.lang.Exception

抛出:

java.lang.Exception

scheduleInstantTaskTest

@Test
public void scheduleInstantTaskTest()
                                    throws java.lang.Exception

抛出:

java.lang.Exception

scheduleInstantTaskWithDelayTest

@Test
public void scheduleInstantTaskWithDelayTest()
                                             throws java.lang.Exception

抛出:

java.lang.Exception

testWorkerSchedulePeriodicallyCancelsSchedulerTask

@Test
public void testWorkerSchedulePeriodicallyCancelsSchedulerTask()
                                                               throws java.lang.Exception

抛出:

java.lang.Exception

testWorkerScheduleRejectedWithDisposedParent

@Test
public void testWorkerScheduleRejectedWithDisposedParent()

testWorkerScheduleSupportZeroPeriodWithDelayPeriod

@Test
public void testWorkerScheduleSupportZeroPeriodWithDelayPeriod()

testWorkerScheduleSupportZeroPeriod

@Test
public void testWorkerScheduleSupportZeroPeriod()
                                                throws java.lang.InterruptedException

抛出:

java.lang.InterruptedException