时间戳

首页 > 解决方案 > 在线程池中查找活动线程的名称：Java 中的 ExecutorService

java - 在线程池中查找活动线程的名称：Java 中的 ExecutorService

问题描述

所以我正在运行一个执行器服务，我想知道所有当前活动/空闲线程的名称或线程 ID。

ExecutorService service = Executors.newCachedThreadPool(ThreadFactory threadFactory)

我不需要知道计数，而是我的执行程序服务中所有活动线程的实际名称/ID。我需要以任何方式识别线程，因为我计划使用适当的命名约定来实现我自己的 ThreadFactory。

例如，如果我的活动线程是 T0、T1、T3，我的线程工厂会将下一个线程命名为 T2。但我找不到获取有关活动线程信息的方法。我怎样才能做到这一点？

PS：任何其他方法也将不胜感激。例如，假设我可以使用名称从 T0 到 T50 的线程。我只希望我当前的线程工厂分配从 T0 到 T50 的任何名称，以便具有相同名称的线程当前不处于活动或空闲状态。

标签： javamultithreadingthreadpoolexecutor

解决方案

我可以自由地为您创建一个样本，我会做的事情。我无法真正测试它：

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. 如果没有地方是免费的，它就会返回null。

这个类可能是线程安全的。但我还没有真正测试过。-statementssynchronized应该防止 cleanUp-Task 和 newThread 方法之间的干扰。但任何其他行动都可能扰乱整个事情。

推荐阅读