mirror of
https://github.com/tiennm99/zfoo.git
synced 2026-10-16 00:15:42 +00:00
feat[thread]: 增加方法,通过线程号寻找对应的线程
This commit is contained in:
1 parent
fed22442e7
commit
e8dd3f9282
1 file changed
+19
@@ -48,6 +48,25 @@ public abstract class ThreadUtils {
|
|||||||
return (null != s) ? s.getThreadGroup() : Thread.currentThread().getThreadGroup();
|
return (null != s) ? s.getThreadGroup() : Thread.currentThread().getThreadGroup();
|
||||||
}
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 通过线程号寻找对应的线程
|
||||||
|
*/
|
||||||
|
public static Thread findThread(long threadId) {
|
||||||
|
var group = currentThreadGroup();
|
||||||
|
while (group != null) {
|
||||||
|
var threads = new Thread[group.activeCount() * 2];
|
||||||
|
var count = group.enumerate(threads, true);
|
||||||
|
for (var i = 0; i < count; i++) {
|
||||||
|
if (threadId == threads[i].getId()) {
|
||||||
|
return threads[i];
|
||||||
|
}
|
||||||
|
}
|
||||||
|
group = group.getParent();
|
||||||
|
}
|
||||||
|
return null;
|
||||||
|
}
|
||||||
|
|
||||||
|
|
||||||
public static void shutdown(ExecutorService executor) {
|
public static void shutdown(ExecutorService executor) {
|
||||||
try {
|
try {
|
||||||
if (!executor.isTerminated()) {
|
if (!executor.isTerminated()) {
|
||||||
|
|||||||
Reference in new issue
Block a user