timeout

timeout.kt

    @Test
    fun fuck1() {
        val dmb = io.reactivex.schedulers.Schedulers.single()
        val watchDog = io.reactivex.schedulers.Schedulers.from(Executors.newSingleThreadExecutor())


        watchDog.scheduleDirect {
            println("watchDog scheduleDirect " + Thread.currentThread().name)
        }

        dmb.scheduleDirect {
            // println("block this thread " + Thread.currentThread().name)
            // Thread.sleep(10_000)
        }

        val watchDogA = AtomicBoolean(false)
        watchDog.scheduleDirect({
            watchDogA.compareAndExchange(false, true)
            println("watchDog scheduleDirect delayed" + Thread.currentThread().name)
        }, 3, TimeUnit.SECONDS)

        Thread.sleep(5_000)

        assertThat(watchDogA.get()).isTrue()
    }

    @Test
    fun fuck2() {
        val dmb = io.reactivex.schedulers.Schedulers.single()
        val watchDog = io.reactivex.schedulers.Schedulers.from(Executors.newSingleThreadExecutor())


        watchDog.scheduleDirect {
            println("watchDog scheduleDirect " + Thread.currentThread().name)
        }

        dmb.scheduleDirect {
            println("block this thread " + Thread.currentThread().name)
            Thread.sleep(10_000)
        }

        val watchDogA = AtomicBoolean(false)
        watchDog.scheduleDirect({
            watchDogA.compareAndExchange(false, true)
            println("watchDog scheduleDirect delayed" + Thread.currentThread().name)
        }, 3, TimeUnit.SECONDS)

        Thread.sleep(5_000)

        assertThat(watchDogA.get()).isTrue()
    }