diff --git a/jetty-util/src/main/java/org/eclipse/jetty/util/thread/ReservedThreadExecutor.java b/jetty-util/src/main/java/org/eclipse/jetty/util/thread/ReservedThreadExecutor.java index f861470cfc4c..3685a3a65529 100644 --- a/jetty-util/src/main/java/org/eclipse/jetty/util/thread/ReservedThreadExecutor.java +++ b/jetty-util/src/main/java/org/eclipse/jetty/util/thread/ReservedThreadExecutor.java @@ -19,6 +19,7 @@ package org.eclipse.jetty.util.thread; import java.io.IOException; +import java.util.Objects; import java.util.Set; import java.util.concurrent.ConcurrentHashMap; import java.util.concurrent.Executor; @@ -196,6 +197,7 @@ public void doStop() throws Exception _threads.stream() .filter(ReservedThread::isReserved) .map(t -> t._thread) + .filter(Objects::nonNull) .forEach(Thread::interrupt); _threads.clear(); _count.getAndSetHi(0);