提交 16d6a205 编写于 作者: oldratlee's avatar oldratlee 🔥

remove unnecessary sleep

上级 d70f33aa
...@@ -159,28 +159,24 @@ class TtlRunnableTest { ...@@ -159,28 +159,24 @@ class TtlRunnableTest {
executorService.submit(ttlRunnable1).get() executorService.submit(ttlRunnable1).get()
assertEquals(1, counterTtl.copyCounter.get()) assertEquals(1, counterTtl.copyCounter.get())
assertEquals(1, counterTtl.beforeExecuteCounter.get()) assertEquals(1, counterTtl.beforeExecuteCounter.get())
Thread.sleep(1)
assertEquals(1, counterTtl.afterExecuteCounter.get()) assertEquals(1, counterTtl.afterExecuteCounter.get())
// do before/after when run // do before/after when run
executorService.submit(ttlRunnable1).get() executorService.submit(ttlRunnable1).get()
assertEquals(if (noTtlAgentRun()) 1 else 2, counterTtl.copyCounter.get()) assertEquals(if (noTtlAgentRun()) 1 else 2, counterTtl.copyCounter.get())
assertEquals(2, counterTtl.beforeExecuteCounter.get()) assertEquals(2, counterTtl.beforeExecuteCounter.get())
Thread.sleep(1)
assertEquals(2, counterTtl.afterExecuteCounter.get()) assertEquals(2, counterTtl.afterExecuteCounter.get())
// do copy when decorate runnable // do copy when decorate runnable
val ttlRunnable2 = if (noTtlAgentRun()) TtlRunnable.get { /* do nothing Runnable */ } else Runnable { /* do nothing Runnable */ } val ttlRunnable2 = if (noTtlAgentRun()) TtlRunnable.get { /* do nothing Runnable */ } else Runnable { /* do nothing Runnable */ }
assertEquals(if (noTtlAgentRun()) 2 else 2, counterTtl.copyCounter.get()) assertEquals(if (noTtlAgentRun()) 2 else 2, counterTtl.copyCounter.get())
assertEquals(2, counterTtl.beforeExecuteCounter.get()) assertEquals(2, counterTtl.beforeExecuteCounter.get())
Thread.sleep(1)
assertEquals(2, counterTtl.afterExecuteCounter.get()) assertEquals(2, counterTtl.afterExecuteCounter.get())
// do before/after when run // do before/after when run
executorService.submit(ttlRunnable2).get() executorService.submit(ttlRunnable2).get()
assertEquals(if (noTtlAgentRun()) 2 else 3, counterTtl.copyCounter.get()) assertEquals(if (noTtlAgentRun()) 2 else 3, counterTtl.copyCounter.get())
assertEquals(3, counterTtl.beforeExecuteCounter.get()) assertEquals(3, counterTtl.beforeExecuteCounter.get())
Thread.sleep(1)
assertEquals(3, counterTtl.afterExecuteCounter.get()) assertEquals(3, counterTtl.afterExecuteCounter.get())
} }
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册