Skip to content

Commit

Permalink
fixup! [FLINK-19109][task] Ignore isLoopRunning in MailboxExecutor.is…
Browse files Browse the repository at this point in the history
…Idle
  • Loading branch information
rkhachatryan committed Sep 3, 2020
1 parent 024c3f3 commit b37d13c
Showing 1 changed file with 20 additions and 0 deletions.
Expand Up @@ -79,6 +79,26 @@ public void tearDown() {
}
}

@Test
public void testIsIdle() throws Exception {
MailboxProcessor processor = new MailboxProcessor(MailboxDefaultAction.Controller::suspendDefaultAction);
MailboxExecutorImpl executor = (MailboxExecutorImpl) processor.getMailboxExecutor(DEFAULT_PRIORITY);

assertFalse(executor.isIdle());

processor.runMailboxStep(); // suspend default action after suspension
processor.mailbox.drain(); // drop any control mails

assertTrue(executor.isIdle());

executor.execute(() -> {}, "");
assertFalse(executor.isIdle());

processor.mailbox.drain();
processor.mailbox.quiesce();
assertFalse(executor.isIdle());
}

@Test
public void testOperations() throws Exception {
AtomicBoolean wasExecuted = new AtomicBoolean(false);
Expand Down

0 comments on commit b37d13c

Please sign in to comment.