ActiveMQ를하고있는 ThreadPoolExecutor가 작동 함께

Question

나는의 ActiveMQ에서 데이터를 가져올하고있는 ThreadPoolExecutor에서 실행 집행에 전달해야합니다. 문제는

, 나는이 작업에 걸릴 유휴 준비 앉아 수영장에서 적어도 하나 개의 스레드가 될 때까지 큐에서 다음 데이터를 가져올 필요가 없습니다.

내가 할 수있는 단지 바쁜 대기 경우 activeCount < poolSize까지. 하지만이 비동기 처리와 함께 모든 솔루션을 주셔서 감사하겠습니다. 미리 감사드립니다.

Answer 1

당신은 내가 조금 혼란 스러워요이

final ThreadPoolExecutor executor=... 
new Thread(new Runnable(){ 
public void run(){ 
    while(true){ 
     if(executor.getActiveCount()<executor.getCorePoolSize()) 
      executor.execute(mq.get()); 
     } 
}).start();