diff --git a/src/main/java/org/xbib/tools/JDBCImporter.java b/src/main/java/org/xbib/tools/JDBCImporter.java index 727d6dec..7849a9bc 100644 --- a/src/main/java/org/xbib/tools/JDBCImporter.java +++ b/src/main/java/org/xbib/tools/JDBCImporter.java @@ -152,6 +152,14 @@ public void run() { logger.error(e.getMessage(), e); } finally { try { + executorService.shutdown(); + if (!executorService.awaitTermination(15, TimeUnit.SECONDS)) { + executorService.shutdownNow(); + if (!executorService.awaitTermination(15, TimeUnit.SECONDS)) { + throw new IOException("pool did not terminate"); + } + } + if (context != null) { context.shutdown(); context = null;