blob: 91a9b7b46ce95dc9e167627e10df899b1cd943a3 [file]
package test.concurrent
import kotlin.concurrent.*
import kotlin.test.*
import java.util.concurrent.atomic.AtomicInteger
import java.util.Timer
import org.junit.Test as test
class TimerTest {
@test fun scheduledTask() {
val counter = AtomicInteger(0)
val timer = Timer()
val task = timer.scheduleAtFixedRate(1000, 100) {
val current = counter.incrementAndGet()
println("Timer fired at $current")
}
Thread.sleep(1500)
task.cancel()
val value = counter.get()
assertTrue(value > 4, "current counter is $value")
}
}