ExecutorService의 활성 스레드

ExecutorService의 활성 스레드

---

현재 실행중인 활성 스레드 수를 결정하는 방법에 대한 아이디어가 ExecutorService있습니까?

---

ThreadPoolExecutor 구현을 사용하고 getActiveCount () 를 호출 합니다.

int getActiveCount() 
// Returns the approximate number of threads that are actively executing tasks.

ExecutorService 인터페이스는이를위한 메소드를 제공하지 않으며 구현에 따라 다릅니다.

---

poolExecutorService 인스턴스의 이름이 다음과 같다고 가정 합니다.

if (pool instanceof ThreadPoolExecutor) {
    System.out.println(
        "Pool size is now " +
        ((ThreadPoolExecutor) pool).getActiveCount()
    );
}

---

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.

ThreadPoolExecutor 클래스에서 사용 가능

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 실행기 = new ThreadPoolExecutor (10, 20, 60L, TimeUnit.SECONDS, new LinkedBlockingQueue ());
        System.out.println (executor.getPoolSize ());
    }
}

그러나이를 위해서는 ExecutorService 객체를 반환하는 Executors 팩토리를 사용하는 대신 ThreadPoolExecutor를 명시 적으로 생성해야합니다. 항상 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) {
        최종 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 ());
    }
}

---

동일한 문제가 발생하여 ExecutorService 인스턴스를 추적하기 위해 간단한 Runnable을 만들었습니다.

import java.util.concurrent.ExecutorService;
import java.util.concurrent.ThreadPoolExecutor;

public class ExecutorServiceAnalyzer implements Runnable
{
    private final ThreadPoolExecutor threadPoolExecutor;
    private final int timeDiff;

    public ExecutorServiceAnalyzer(ExecutorService executorService, int timeDiff)
    {
        this.timeDiff = timeDiff;
        if (executorService instanceof ThreadPoolExecutor)
        {
            threadPoolExecutor = (ThreadPoolExecutor) executorService;
        }
        else
        {
            threadPoolExecutor = null;
            System.out.println("This executor doesn't support ThreadPoolExecutor ");
        }

    }

    @Override
    public void run()
    {
        if (threadPoolExecutor != null)
        {
            do
            {
                System.out.println("#### Thread Report:: Active:" + threadPoolExecutor.getActiveCount() + " Pool: "
                        + threadPoolExecutor.getPoolSize() + " MaxPool: " + threadPoolExecutor.getMaximumPoolSize()
                        + " ####");
                try
                {
                    Thread.sleep(timeDiff);
                }
                catch (Exception e)
                {
                }
            } while (threadPoolExecutor.getActiveCount() > 1);
            System.out.println("##### Terminating as only 1 thread is active ######");
        }

    }
}

실행 프로그램과 함께 이것을 사용하여 ThreadPool의 상태를 얻을 수 있습니다.

전의

ExecutorService executorService = Executors.newFixedThreadPool(4);
    executorService.execute(new ExecutorServiceAnalyzer(executorService, 1000));

---

Place a static volatile counter on the thread which is updated whenever the thread is activated and deactivated. Also, see the API.

참고URL : https://stackoverflow.com/questions/80787/active-threads-in-executorservice