ThreadTest.java

import com.carrotsearch.randomizedtesting.RandomizedTest;
import com.carrotsearch.randomizedtesting.annotations.ThreadLeakScope;
import org.junit.AfterClass;
import org.junit.Assert;
import org.junit.BeforeClass;
import org.junit.Test;

import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;

@ThreadLeakScope(ThreadLeakScope.Scope.SUITE)
public class ThreadTest extends RandomizedTest {

    private static ExecutorService executor;

    @BeforeClass
    public static void startExecutorService() {
        executor = Executors.newFixedThreadPool(1);
    }

    @AfterClass
    public static void shutdownPool() throws InterruptedException {
        executor.shutdown();
        executor = null;
    }

    @Test
    public void testFoo() throws Exception {
        System.out.println("Test thread foo is " + getRandom().nextInt());
        executor.submit(() -> System.out.println("Executor thread foo is " + getRandom().nextInt())).get();
    }

    @Test
    public void testBar() throws Exception {
        System.out.println("Test thread bar is " + getRandom().nextInt());
        executor.submit(() -> System.out.println("Executor thread bar is " + getRandom().nextInt())).get();
        Assert.assertTrue(false);
    }
}