Активные потоки в ExecutorService

Проверьте исходный код на Executors.newFixedThreadPool ():

return new ThreadPoolExecutor(nThreads, nThreads,
                              0L, TimeUnit.MILLISECONDS,
                              new LinkedBlockingQueue<Runnable>());

ThreadPoolExecutor имеет getActiveCount () метод. Таким образом, Вы могли бы или бросить ExecutorService в ThreadPoolExecutor, одерское использование вышеупомянутый код непосредственно для получения того. Можно тогда вызвать getActiveCount ().

Интерфейс ExecutorService не определяет метод для исследования количества рабочих потоков в пуле, поскольку это - деталь реализации

public int getPoolSize()
Returns the current number of threads in the pool.

, доступно на классе

import java.util.concurrent.LinkedBlockingQueue;
import java.util.concurrent.ThreadPoolExecutor;
import java.util.concurrent.TimeUnit;


public class PoolSize {

    public static void main(String[] args) {
        ThreadPoolExecutor executor = new ThreadPoolExecutor(10, 20, 60L, TimeUnit.SECONDS, new LinkedBlockingQueue());
        System.out.println(executor.getPoolSize());
    }
}

ThreadPoolExecutor, Но это требует, чтобы Вы явно создали ThreadPoolExecutor, вместо того, чтобы использовали фабрику Исполнителей, которая возвращает объекты ExecutorService. Вы могли всегда создавать свою собственную фабрику, которая возвратила ThreadPoolExecutors, но Вас все еще оставят с невоспитанностью использования конкретного типа, не его интерфейса.

Одна возможность состояла бы в том, чтобы обеспечить Ваш собственный ThreadFactory, который создает потоки в известной группе потока, которая Вы можете тогда количество

import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.ThreadFactory;


public class PoolSize2 {

    public static void main(String[] args) {
        final ThreadGroup threadGroup = new ThreadGroup("workers");

        ExecutorService executor = Executors.newCachedThreadPool(new ThreadFactory() {
            public Thread newThread(Runnable r) {
                return new Thread(threadGroup, r);
            }
        });

        System.out.println(threadGroup.activeCount());
    }
}

Поместите статический энергозависимый счетчик в поток, который обновляется каждый раз, когда поток активируется и деактивируется. Кроме того, посмотрите API.