查找线程池中活动线程的名称:java 中的 ExecutorService
Finding the Names of active threads inside a threadpool : ExecutorService in java
所以我是 运行 一个执行服务,我想知道所有当前 active/idle 线程的名称或线程 ID。
ExecutorService service = Executors.newCachedThreadPool(ThreadFactory threadFactory)
我不需要知道计数,但我的执行程序服务中所有活动线程的实际 names/IDs。我需要以任何方式识别线程,因为我计划使用适当的命名约定实现我自己的 ThreadFactory。
例如,如果我的活动线程是 T0、T1、T3,我的线程工厂会将下一个线程命名为 T2。但是我找不到获取有关活动线程的信息的方法。
我该怎么做?
PS : 任何其他方法也将不胜感激。例如,假设我可以接受名称从 T0 到 T50 的线程。我只希望我当前的线程工厂分配从 T0 到 T50 的任何名称,以便具有相同名称的线程当前不处于活动状态或空闲状态。
改打电话
Executors.newCachedThreadPool(ThreadFactory threadFactory)
并传递您的 ThreadFactory 实现。您可以在线程创建时管理线程名称。
通过 jconsole 或 jvisual vm 连接到您的 运行 程序。它将为您提供所有 运行 线程及其名称。
我很乐意为您创建一个样本,我会做的事情。虽然我无法真正测试它:
public class CachingThreadFactory implements ThreadFactory{
// amount of active threads at max
private static final int THREAD_POOL_MAX_SIZE = 8;
// interval in milliseconds of the clean up task
private static final int CLEAN_UP_INTERVAL = 2000;
// the actual cache
private final Thread[] cachedThreads = new Thread[THREAD_POOL_MAX_SIZE];
// clean up task definition
{
new Timer().scheduleAtFixedRate(new CleanUpTask(), 0, CLEAN_UP_INTERVAL);
}
@Override
public synchronized Thread newThread(Runnable r){
for(int i = 0; i < cachedThreads.length; i++){
if(cachedThreads[i] == null){
return cachedThreads[i] = new Thread(r, "T" + i);
}
}
return null;
}
private final class CleanUpTask extends TimerTask{
@Override
public void run(){
synchronized(CachingThreadFactory.this){
for(int i = 0; i < cachedThreads.length; i++){
final Thread thread = cachedThreads[i];
if(thread != null && !thread.isAlive()){
cachedThreads[i] = null; // unset
}
}
}
}
}
}
这个工厂缓存它在数组中创建的每个线程。然后它异步运行一个 cleanUpTask,检查数组中的线程(如果有的话)是否仍然存在。如果不是,它们将被删除。
newThread
方法遍历缓存,找到尚未使用的索引,然后使用该索引创建 Thread
的名称。如果没有地方是免费的它只是 returns null
.
这个class可能是线程安全的。但我还没有真正测试过它。 synchronized
语句应该防止 cleanUp-Task 和 newThread 方法之间的干扰。但是任何其他的动作都可能会打乱整个事情。
所以我是 运行 一个执行服务,我想知道所有当前 active/idle 线程的名称或线程 ID。
ExecutorService service = Executors.newCachedThreadPool(ThreadFactory threadFactory)
我不需要知道计数,但我的执行程序服务中所有活动线程的实际 names/IDs。我需要以任何方式识别线程,因为我计划使用适当的命名约定实现我自己的 ThreadFactory。
例如,如果我的活动线程是 T0、T1、T3,我的线程工厂会将下一个线程命名为 T2。但是我找不到获取有关活动线程的信息的方法。 我该怎么做?
PS : 任何其他方法也将不胜感激。例如,假设我可以接受名称从 T0 到 T50 的线程。我只希望我当前的线程工厂分配从 T0 到 T50 的任何名称,以便具有相同名称的线程当前不处于活动状态或空闲状态。
改打电话
Executors.newCachedThreadPool(ThreadFactory threadFactory)
并传递您的 ThreadFactory 实现。您可以在线程创建时管理线程名称。
通过 jconsole 或 jvisual vm 连接到您的 运行 程序。它将为您提供所有 运行 线程及其名称。
我很乐意为您创建一个样本,我会做的事情。虽然我无法真正测试它:
public class CachingThreadFactory implements ThreadFactory{
// amount of active threads at max
private static final int THREAD_POOL_MAX_SIZE = 8;
// interval in milliseconds of the clean up task
private static final int CLEAN_UP_INTERVAL = 2000;
// the actual cache
private final Thread[] cachedThreads = new Thread[THREAD_POOL_MAX_SIZE];
// clean up task definition
{
new Timer().scheduleAtFixedRate(new CleanUpTask(), 0, CLEAN_UP_INTERVAL);
}
@Override
public synchronized Thread newThread(Runnable r){
for(int i = 0; i < cachedThreads.length; i++){
if(cachedThreads[i] == null){
return cachedThreads[i] = new Thread(r, "T" + i);
}
}
return null;
}
private final class CleanUpTask extends TimerTask{
@Override
public void run(){
synchronized(CachingThreadFactory.this){
for(int i = 0; i < cachedThreads.length; i++){
final Thread thread = cachedThreads[i];
if(thread != null && !thread.isAlive()){
cachedThreads[i] = null; // unset
}
}
}
}
}
}
这个工厂缓存它在数组中创建的每个线程。然后它异步运行一个 cleanUpTask,检查数组中的线程(如果有的话)是否仍然存在。如果不是,它们将被删除。
newThread
方法遍历缓存,找到尚未使用的索引,然后使用该索引创建 Thread
的名称。如果没有地方是免费的它只是 returns null
.
这个class可能是线程安全的。但我还没有真正测试过它。 synchronized
语句应该防止 cleanUp-Task 和 newThread 方法之间的干扰。但是任何其他的动作都可能会打乱整个事情。