ThreadPoolExecutor를 사용하는 활성 작업 수

Question

ThreadPoolExecutor를 사용하여 Java 응용 프로그램에서 작업을 실행하고 있습니다. 나는 Executor 큐에서 어떤 시점에서 큐의 활성 작업의 수를 얻고 자하는 요구 사항을 가지고 있습니다. ThreadPoolExecutor에 대해 javadoc을 찾아 보았고 두 가지 관련 메서드 인 getTaskCount() 및 getCompletedTaskCount()을 발견했습니다.

설명서에 따라 위의 두 가지 방법 각각에서 예약 된 작업 수와 완료된 작업 수를 얻을 수있었습니다. 그러나 어떤 시점에서든 큐의 활성 작업 수를 얻기위한 솔루션을 찾을 수 없습니다. 나는 다음과 같이 할 수 있습니다 :

getTaskCount() = getCompletedTaskCount() + failed tasks + active tasks 

그러나 실패한 작업의 수는 의도 한 계산에 도달하기 위해 직접 사용할 수 없습니다.

여기에 뭔가가 있습니까?

Answer 1

사용하려는 계산에 실패한 횟수를 알 필요가 있다고 생각하지 않습니다.

long submitted = executor.getTaskCount(); 
long completed = executor.getCompletedTaskCount(); 
long notCompleted = submitted - completed; // approximate 

(대략) 충분할 것입니다.

---

또는, size()와 getQueue()를 사용할 수 있습니다

int queued = executor.getQueue().size(); 
int active = executor.getActiveCount(); 
int notCompleted = queued + active; // approximate 

이 대답은 당신이 "아직 완료되지"수를 찾고있는 가정. 당신의 질문은 모순되어서 당신이 무엇을 요구하는지 완전히 확신하지 못합니다. 귀하의 질문에 대한 나의 코멘트에 답글이 틀리면, 그에 따라이 답변을 업데이트하겠습니다.

Answer 2

beforeExecute 및 afterExecute 메서드를 사용해 보셨습니까? 이들은 작업이 실행되기 전후에 호출됩니다. after execute 메서드는 throwable을 두 번째 인수로 제공하기 때문에 작업이 실패한 시점을 알 수 있습니다.

beforeExecute가 활성 작업의 값을 증가시키고 afterExecute가 감소 시키도록 후크를 추가 할 수 있습니다. 물론 이러한 메서드는 각각의 필드에서 호출되므로 상호 잠금 개체에서 결과를 동기화해야합니다.

이러한 메서드를 사용하려면 선택한 ThreadPoolExecutor 개체를 재정의하고 거기에 후크를 추가하십시오.

예를 들어, 다음 코드는 희망 작동합니다 :

public class MyExecutor extends ThreadPoolExecutor { 
     //Lock object used for synchronization 
     private final Object lockObject = new Object(); 
     //Contains the active task count 
     private int activeTaskCount = 0; 
     //Failed task count 
     private int failedTaskCount = 0; 
     private int succeededTaskCount = 0; 

     public MyExecutor() { 
      //call super here with your parameters; 
     } 

     public int getActiveTaskCount(){ 
      synchronized(lockObject){ 
       return activeTaskCount; 
      } 
     } 

     public int getFailedTaskCount(){ 
      synchronized(lockObject){ 
       return failedTaskCount ; 
      } 
     } 

     public int getSucceededTaskCount(){ 
      synchronized(lockObject){ 
       return succeededTaskCount ; 
      } 
     } 

     protected void beforeExecute(Thread t, 
          Runnable r){ 
      super.beforeExecute(t,r); 
      synchronized(lockObject){ 
       activeTaskCount++; 
      } 
     } 

     protected void afterExecute(Runnable r,Throwable t){ 
      super.afterExecute(r,t); 
      synchronized(lockObject){ 
       activeTaskCount--; 
       if(t!=null){ 
        failedTaskCount++; 
       }else{ 
        succeededTaskCount++; 
       } 
      } 
     } 

}