Searched refs:Interrupter (Results 1 – 1 of 1) sorted by relevance
179 threadPool.submit(new Interrupter(Thread.currentThread())); in testDrain_throws()198 new Interrupter(mainThread).run(); in testDrainUninterruptibly_doesNotThrow()251 threadPool.submit(new Interrupter(Thread.currentThread())); in assertInterruptibleDrained()267 threadPool.submit(new Interrupter(Thread.currentThread())); in assertUninterruptibleDrained()301 private static class Interrupter implements Runnable { class in QueuesTest304 Interrupter(Thread threadToInterrupt) { in Interrupter() method in QueuesTest.Interrupter