The interrupted status of the thread is cleared when this exception occurs.ĭescription: This variant of the sleep method causes the thread to invoke it to sleep or temporarily stop its execution for the given number of milliseconds. InterruptedException => if any other thread interrupts the current thread.IllegalArgumentException => if millis value is negative or nanos value if out of range.nanos => additional nanoseconds for which the thread can sleep.millis => the duration in milliseconds for which the thread has to sleep.Prototype: public static void sleep (long millis, int nanos) throws InterruptdException However, while sleeping, the thread does not lose the monitor or lock ownership. When this exception occurs, the interrupted status of the thread is cleared.ĭescription: This variation of sleep method makes the current thread to sleep or temporarily stops its execution for the given number of milliseconds (provided in method argument). IllegalArgumentException => if millis is negative.Parameters: millis => the duration of time in milliseconds for which the thread sleeps. Prototype: public static void sleep (long millis) throws InterruptedException The prototype of both the variants of the sleep () method is described below. The Thread class of Java provides two variants of the sleep method. Thread.sleep() With Negative Sleep Time Value.If an error occurs, it will be propagated downstream.Įxample: Flux.just('one', 'two', 'three'). It is used to delay the Flux by generating a trigger Publisher for each element, then wait until all trigger Publishers terminates. delaySubscription(Flux.just(1,2,3).delayElements(Duration.ofSeconds(5))) It delays the subscription until the passed Publisher sends a signal or complete. The last variation allows us to pass a Publisher. It's used to add subscription delay to the Flux by the given Duration. If an error occurs, it will be propagated downstream.Įxample: Flux.just('one', 'two', 'three') It is used to delay the Mono by generating a trigger Publisher, then wait until the trigger Publisher terminates. delaySubscription(lay(Duration.ofSeconds(5))) It requires a Publisher in the parameter. The usage of the last variation is somewhat different to the other two variations. delaySubscription(Duration.ofSeconds(2)) It is used to add subscription delay to the Mono by the given Duration. Delay will not be applied on empty Mono or error signal. It is used to delay the Mono element by the given Duration. It is used to delay onNext signal by the given Duration. delayElement(Duration.ofSeconds(2), scheduler) Scheduler scheduler = Schedulers.newElastic('es1') However, most delay operators allow us to pass a second argument to set the scheduler, replacing the default setting which uses parallel scheduler.

Adding publishOn after the delay operator allows you to switch the execution to another scheduler you want. That also happens even if you add publishOn or subscribeOn before the delay operator. If you run the code, you will find that onNext signal is received on a parallel thread. Let's take a look at the example below Mono.just('one') If you don't already understand about publishOn, you can read about it here. publishOn(Schedulers.parallel()) which means the operators below the delay operator are affected. The important thing you need to aware if you use a Reactor's delay method is some of them switches the execution to a parallel scheduler by default. In Project Reactor, we can add delay for a certain duration to Mono or Flux publisher.

Simple delay function in java