reactor.test.util

类 RaceTestUtils

java.lang.Object

reactor.test.util.RaceTestUtils

public class RaceTestUtils
extends java.lang.Object

作者:

Stephane Maldini, David Karnok

构造器概要

构造器

构造器和说明
RaceTestUtils()

方法概要

限定符和类型	方法和说明
static void	race(int timeoutSeconds, Scheduler s, java.lang.Runnable... rs) Synchronizes the execution of several Runnables as much as possible to test race conditions.
static void	race(java.lang.Runnable... rs) Synchronizes the execution of several Runnables as much as possible to test race conditions.
static void	race(java.lang.Runnable r1, java.lang.Runnable r2) Synchronizes the execution of two Runnables as much as possible to test race conditions.
static void	race(java.lang.Runnable r1, java.lang.Runnable r2, Scheduler s) 已过时。 Use race(Scheduler, Runnable...). To be removed in 3.6.0, at the earliest.
static void	race(Scheduler s, java.lang.Runnable... rs) Synchronizes the execution of several Runnables as much as possible to test race conditions.
static <T> boolean	race(T initial, java.util.function.Function<? super T,? extends T> race, java.util.function.Predicate<? super T> stopRace, java.util.function.BiPredicate<? super T,? super T> terminate) Synchronizes the execution of two concurrent state modifications as much as possible to test race conditions.

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

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

构造器详细资料

RaceTestUtils

public RaceTestUtils()

方法详细资料

race

public static <T> boolean race(T initial,
                               java.util.function.Function<? super T,? extends T> race,
                               java.util.function.Predicate<? super T> stopRace,
                               java.util.function.BiPredicate<? super T,? super T> terminate)

Synchronizes the execution of two concurrent state modifications as much as possible to test race conditions. The method blocks until the given Predicate matches. It performs a BiPredicate test at the end to validate the end result.

参数:

initial - the initial state

race - the state-modification Function

stopRace - the stop condition for the race loop, as a Predicate

terminate - the validation check, as a BiPredicate

返回:

the result of the terminate check

race

public static void race(java.lang.Runnable... rs)

Synchronizes the execution of several Runnables as much as possible to test race conditions. The method blocks until all have run to completion.

参数:

rs - the runnables to execute

race

public static void race(java.lang.Runnable r1,
                        java.lang.Runnable r2)

Synchronizes the execution of two Runnables as much as possible to test race conditions. The method blocks until both have run to completion. Kept for binary compatibility, see the varargs variant.

参数:

r1 - the first runnable to execute

r2 - the second runnable to execute

另请参阅:

race(Runnable...)

race

@Deprecated
public static void race(java.lang.Runnable r1,
                                     java.lang.Runnable r2,
                                     Scheduler s)

已过时。 Use race(Scheduler, Runnable...). To be removed in 3.6.0, at the earliest.

Synchronizes the execution of two Runnable as much as possible to test race conditions. The method blocks until both have run to completion.

参数:

s - the Scheduler on which to execute the runnables

r1 - the first runnable

r2 - the second runnable

race

public static void race(Scheduler s,
                        java.lang.Runnable... rs)

Synchronizes the execution of several Runnables as much as possible to test race conditions. The method blocks until all have run to completion, with a 5s timeout.

参数:

s - the Scheduler on which to execute the runnables

rs - the runnables to execute

race

public static void race(int timeoutSeconds,
                        Scheduler s,
                        java.lang.Runnable... rs)

Synchronizes the execution of several Runnables as much as possible to test race conditions. The method blocks until all have run to completion, with a configurable timeout (allowing for debugging sessions to use a larger timeout).

参数:

timeoutSeconds - the number of seconds after which the race is considered timed out. intended for debugging purposes.

s - the Scheduler on which to execute the runnables

rs - the runnables to execute