Будущее сопрограммы Kotlin ожидает с тайм-аутом (без отмены) ⇐ JAVA

[Anonymous]

Учитывая, что у нас есть CompletableFuture f, в приостанавливаемой области видимости Kotlin мы можем вызвать f.await() и приостановить работу до тех пор, пока это не будет выполнено.
У меня возникли проблемы с реализацией аналогичной функции с сигнатурой f.await(t), которая должна приостанавливаться на максимум t миллисекунд или возвращаться раньше, если Future завершилось в течение этого времени (в зависимости от того, что произойдет раньше).
Вот что я попробовал.
/**
* Suspend current method until future is done or specified duration expires,
* whichever happens first without cancelling the future.
* Returns true if it's done, false otherwise.
*/
suspend fun ListenableFuture.await(duration: Long): Boolean {
val future = this
try {
withTimeout(duration) {
withContext(NonCancellable) { // this does not help either
future.await() // i do not expect the future itself to be cancelled
}
}
} catch (t: TimeoutCancellationException) {
// we expected this
} catch (e: Throwable) {
e.printStackTrace()
}

return future.isDone

}

fun main(args: Array) = runBlocking {
val future = GlobalScope.future {
try {
repeat(5) {
println("computing")
delay(500)
}
println("complete")
} finally {
withContext(NonCancellable) {
println("cancelling")
delay(500)
println("cancelled")
}
}
}

for (i in 0..10) {
if (future.await(2000)) {
println("checking : done")
} else {
println("checking : not done")
}
}
}

Мне тоже нужна подобная функция для работы. Но, возможно, решение для этого также поможет мне в этом...
Вывод:
computing
computing
computing
computing
checking : done
checking : done
checking : done
checking : done
cancelling
checking : done
checking : done
checking : done
checking : done
checking : done
checking : done
checking : done


Подробнее здесь: https://stackoverflow.com/questions/543 ... ncellation