Run coroutine inside @Scheduled

Question

I want to run a periodic task. In Spring MVC it works flawlessly. Now I want to integrate Spring Webflux + Kotlin Coroutines. How can I call suspended functions in the @Scheduled method? I want it to wait until the suspended function is finished.

/// This function starts every 00:10 UTC
@Scheduled(cron = "0 10 0 * * *", zone = "UTC")
fun myScheduler() {
    // ???
}

suspend fun mySuspendedFunction() {
    // business logic
}

Lundy

Answer 1

fun myScheduler() {
    runBlocking {
        mySuspendedFunction()
    }
}

This way coroutines will run in the thread that was blocked. If you need to run the code in a different thread or execute several coroutines in parallel, you can pass a dispatcher (e.g. Dispatchers.Default, Dispatchers.IO) to runBlocking() or use withContenxt().

Geographical

Answer 2

Since Spring 6.1, this is supported ootb.

https://docs.spring.io/spring-framework/reference/integration/scheduling.html#scheduling-annotation-support-scheduled-reactive

@Scheduled(cron = "0 10 0 * * *", zone = "UTC")
suspend fun myScheduler() {
    mySuspendedFunction()
}

Speck