reactor.core.scheduler

类 BoundedElasticSchedulerTest

java.lang.Object

reactor.core.scheduler.AbstractSchedulerTest

reactor.core.scheduler.BoundedElasticSchedulerTest

public class BoundedElasticSchedulerTest
extends AbstractSchedulerTest

作者:

Simon Baslé

字段概要

从类继承的字段 reactor.core.scheduler.AbstractSchedulerTest

afterTest

构造器概要

构造器

构造器和说明
BoundedElasticSchedulerTest()

方法概要

限定符和类型	方法和说明
void	blockingTasksWith100kLimit()
void	defaultBoundedElasticConfigurationIsConsistentWithJavadoc()
void	delayedTasksWith100kLimit()
void	doubleSubscribeOn()
static void	dumpThreads()
void	estimateRemainingTaskCapacityIsSumOfWorkers()
void	estimateRemainingTaskCapacityWithSomeUnobservableWorkers()
void	estimateRemainingTaskCapacityWithUnobservableOnly()
void	evictionForWorkerScheduling()
void	extraWorkersShareBackingExecutorAndBoundedState()
void	gh1992()
void	lifoEvictionNoThreadRegrowth()
void	maximumTtl()
void	negativeTaskCap()
void	negativeThreadCap()
void	negativeTtl()
void	pickSetIdleRaceBusy()
void	pickSetIdleRaceIdle()
void	publishOnDisposesWorkerWhenCancelled()
void	regrowFromEviction()
void	scanCapacityBounded()
void	scanCapacityUnbounded()
void	scanName()
void	scanWorkerName()
void	startNoOpIfStarted()
void	subscribeOnDisposesWorkerWhenCancelled()
void	taskCapIsOnExecutorAndNotWorker()
void	testGh1973()
void	testLargeNumberOfWorkers()
void	testSmallTaskCapacityJustEnough()
void	testSmallTaskCapacityReached()
void	TODO_TEST_MUTUALLY_DELAYING_TASKS()
void	toStringOfTtlInSplitSeconds()
void	toStringOfTtlUnderOneSecond()
void	transitionsToIdleAfterRejectionAndFollowingCompletion()
void	userWorkerShutdownBySchedulerDisposal(boolean disposeGracefully)
void	whenCapReachedPicksLeastBusyExecutor()
void	workerRejectsTasksAfterBeingDisposed()
void	zeroTaskCap()
void	zeroThreadCap()
void	zeroTtl()

从类继承的方法 reactor.core.scheduler.AbstractSchedulerTest

acceptTaskAfterStartStopStart, directScheduleAndDispose, directScheduleAndDisposeDelay, directScheduleAndDisposePeriod, restartSupport, workerScheduleAndDispose, workerScheduleAndDisposeDelay, workerScheduleAndDisposePeriod

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

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

构造器详细资料

BoundedElasticSchedulerTest

public BoundedElasticSchedulerTest()

方法详细资料

dumpThreads

@AfterAll
public static void dumpThreads()

extraWorkersShareBackingExecutorAndBoundedState

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

抛出:

java.lang.InterruptedException

doubleSubscribeOn

@Test
public void doubleSubscribeOn()

testLargeNumberOfWorkers

@Test
 @Tag(value="slow")
public void testLargeNumberOfWorkers()
                                                          throws java.lang.InterruptedException

抛出:

java.lang.InterruptedException

testSmallTaskCapacityReached

@Test
public void testSmallTaskCapacityReached()

testSmallTaskCapacityJustEnough

@Test
public void testSmallTaskCapacityJustEnough()

TODO_TEST_MUTUALLY_DELAYING_TASKS

@Test
public void TODO_TEST_MUTUALLY_DELAYING_TASKS()

whenCapReachedPicksLeastBusyExecutor

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

抛出:

java.lang.InterruptedException

startNoOpIfStarted

@Test
public void startNoOpIfStarted()

negativeTtl

@Test
public void negativeTtl()

zeroTtl

@Test
public void zeroTtl()

maximumTtl

@Test
public void maximumTtl()

negativeThreadCap

@Test
public void negativeThreadCap()

zeroThreadCap

@Test
public void zeroThreadCap()

negativeTaskCap

@Test
public void negativeTaskCap()

zeroTaskCap

@Test
public void zeroTaskCap()

evictionForWorkerScheduling

@Test
public void evictionForWorkerScheduling()

lifoEvictionNoThreadRegrowth

@Test
 @Tag(value="slow")
public void lifoEvictionNoThreadRegrowth()
                                                              throws java.lang.InterruptedException

抛出:

java.lang.InterruptedException

userWorkerShutdownBySchedulerDisposal

@ValueSource(booleans={true,false})
public void userWorkerShutdownBySchedulerDisposal(boolean disposeGracefully)
                                                                                throws java.lang.InterruptedException

抛出:

java.lang.InterruptedException

regrowFromEviction

@Test
public void regrowFromEviction()

taskCapIsOnExecutorAndNotWorker

@Test
public void taskCapIsOnExecutorAndNotWorker()

estimateRemainingTaskCapacityIsSumOfWorkers

@Test
public void estimateRemainingTaskCapacityIsSumOfWorkers()

estimateRemainingTaskCapacityWithSomeUnobservableWorkers

@Test
public void estimateRemainingTaskCapacityWithSomeUnobservableWorkers()

estimateRemainingTaskCapacityWithUnobservableOnly

@Test
public void estimateRemainingTaskCapacityWithUnobservableOnly()

workerRejectsTasksAfterBeingDisposed

@Test
public void workerRejectsTasksAfterBeingDisposed()

blockingTasksWith100kLimit

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

抛出:

java.lang.InterruptedException

delayedTasksWith100kLimit

@Test
public void delayedTasksWith100kLimit()

subscribeOnDisposesWorkerWhenCancelled

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

抛出:

java.lang.InterruptedException

publishOnDisposesWorkerWhenCancelled

@Test
public void publishOnDisposesWorkerWhenCancelled()

pickSetIdleRaceBusy

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

pickSetIdleRaceIdle

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

gh1992

@Test
public void gh1992()

testGh1973

@Test
 @Tag(value="slow")
public void testGh1973()
                                            throws java.lang.InterruptedException

抛出:

java.lang.InterruptedException

defaultBoundedElasticConfigurationIsConsistentWithJavadoc

@Test
public void defaultBoundedElasticConfigurationIsConsistentWithJavadoc()

scanName

@Test
public void scanName()

scanWorkerName

@Test
public void scanWorkerName()

scanCapacityBounded

@Test
public void scanCapacityBounded()

scanCapacityUnbounded

@Test
public void scanCapacityUnbounded()

toStringOfTtlInSplitSeconds

@Test
public void toStringOfTtlInSplitSeconds()

toStringOfTtlUnderOneSecond

@Test
public void toStringOfTtlUnderOneSecond()

transitionsToIdleAfterRejectionAndFollowingCompletion

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

抛出:

java.lang.InterruptedException