mirror of
https://github.com/Suwayomi/Suwayomi-Server.git
synced 2026-06-30 09:24:34 -05:00
Switch to LegacyMessageQueue (#2054)
This commit is contained in:
@@ -53,4 +53,34 @@ class LooperTest {
|
||||
thread.mHandler!!.looper.quit()
|
||||
// thread.join()
|
||||
}
|
||||
|
||||
@Test
|
||||
fun loopTest() {
|
||||
val thread = LooperThread()
|
||||
thread.start()
|
||||
val sb = StringBuilder()
|
||||
val expected = StringBuilder()
|
||||
val latch = CountDownLatch(1)
|
||||
assertTrue(thread.latch.await(5, TimeUnit.SECONDS))
|
||||
val n = 100
|
||||
|
||||
for (i in 0 until n) {
|
||||
thread.mHandler!!.post {
|
||||
Thread.sleep(10)
|
||||
sb.append("$i")
|
||||
}
|
||||
expected.append("$i")
|
||||
}
|
||||
|
||||
thread.mHandler!!.post {
|
||||
latch.countDown()
|
||||
}
|
||||
|
||||
assertNotEquals(expected.toString(), sb.toString())
|
||||
assertTrue(latch.await(5, TimeUnit.SECONDS), "only got to $sb")
|
||||
|
||||
assertEquals(expected.toString(), sb.toString())
|
||||
thread.mHandler!!.looper.quit()
|
||||
// thread.join()
|
||||
}
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user