春の非同期タスク数の取得方法私の春のアプリケーションで

Question

、私はmyServiceという中で、次のようなAsync方法ました：ここ

@Async("threadPoolTaskExecutor") 
public void exportObject(String id) { 
    System.out.println("exporting " + id); 
    try { 
     Thread.sleep(5000); 
    } catch (InterruptedException e) { 
     e.printStackTrace(); 
    } 
    System.out.println("exported " + id); 
} 

は私が呼んでいる私のController内部TaskExecutor豆

@Bean(name = "threadPoolTaskExecutor") 
public TaskExecutor getTaskExecutor() { 
    ThreadPoolTaskExecutor threadPoolTaskExecutor = new ThreadPoolTaskExecutor(); 
    threadPoolTaskExecutor.setCorePoolSize(5); 
    threadPoolTaskExecutor.setMaxPoolSize(5); 

    return threadPoolTaskExecutor; 
} 

を作成しています方法ですが次のようなAsyncメソッド：

for(int i = 0; i < 100; i++){ 
    myService.exportObject(i+""); 
} 

今私は取得したいキューに追加された保留中の非同期タスクの総数。どのように私はこれを得ることができますか？私はコントローラクラスで以下を試しましたが、TaskExecutorにはこの目的を果たすメソッドがありません。

@Autowire 
private TaskExecutor taskExecutor; 

public int getPendingTaskCount(){ 
    // taskExecutor.getPendingTaskCount(); // ? 
} 

Answer 1

あなたはは行うことができます：

long result = threadPoolTaskExecutor.getThreadPoolExecutor().getTaskCount() - 
       threadPoolTaskExecutor.getThreadPoolExecutor().getCompletedTaskCount(); 

しかし、それはおおよそ、これらの各メソッドは、実際にロック用ReentrantLockのを使用していますでしょう。