И да, я в каждом тесте делаю .get() на каждый Future - это гарантирует завершение всех потоков до выхода из теста.