#60 check for max threads

yegor256 · Apr 23, 2018 · 2a5d637 · 2a5d637
1 parent 7ec0337
commit 2a5d637
Showing 1 changed file with 14 additions and 0 deletions.
diff --git a/src/main/java/io/wring/agents/Routine.java b/src/main/java/io/wring/agents/Routine.java
@@ -116,6 +116,20 @@ public void start() {
     @Override
     @SuppressWarnings("PMD.PrematureDeclaration")
     public void run() {
+        // @checkstyle MagicNumber (1 line)
+        if (Thread.getAllStackTraces().size() > 64) {
+            throw new IllegalStateException(
+                String.format(
+                    "Too many threads already, can't start: %s",
+                    String.join(
+                        "; ",
+                        new Mapped<>(
+                            Thread::getName, Thread.getAllStackTraces().keySet()
+                        )
+                    )
+                )
+            );
+        }
         final long start = System.currentTimeMillis();
         final Collection<Future<?>> futures = new ArrayList<>(this.threads);
         final ExecutorService runner = Executors.newFixedThreadPool(