Listet alle laufenden/wartenden Threads in ThreadPoolTaskExecutor auf

Question

Ich verwende einen ThreadPoolTaskExecutor im Frühling, um meine Aufgaben zu planen.

Gibt es eine Möglichkeit, eine Liste oder etwas von jedem laufenden und wartenden Thread des Tasks Executor/Pool zu erhalten?

Answer 1

Vielleicht nicht sehr elegant, aber auf diese Weise kann ich alle Threads von einem bekannten Executor (mit dem Präfix) bekommen.

Set<Thread> threadSet = Thread.getAllStackTraces().keySet(); 
for (Thread thread : threadSet) { 
    if (thread.getName().startsWith("MyExecutor")) { 
    System.out.println(thread.getName() + " " + thread.getState()); 
    for (StackTraceElement s : thread.getStackTrace()) { 
     System.out.println(s); 
    } 
    } 
} 

Dank Surveon für seine Andeutung, upvoted ich für seine approch die Warteschlange Fäden zu erhalten.

Answer 2

Es sieht so aus, als könnten Sie den zugrunde liegenden ThreadPoolExecutor erreichen, indem Sie getThreadPoolExecutor anrufen.

Damit können Sie zumindest auf die Warteschlange zugreifen.

Answer 3

Ein möglicher Weg ist Reflexion oder Feder ReflectionUtils oder ReflectionTestUtils zu verwenden ..

Ich benutzen ReflectionTestUtils in meinem Junit das Szenario zu testen, wenn ein oder mehr Schlaf Fäden unterbrochen wird.

Der Code-Snippet ist:

Collection<Object> workers = (Collection<Object>) ReflectionTestUtils.getField(responseHandlerTaskExecutor.getThreadPoolExecutor(), "workers"); 

for(Object worker : workers){ 
    Thread workerThread = (Thread)ReflectionTestUtils.getField(worker, "thread"); 
    workerThread.interrupt(); 
}