アクセス提出物</p> <p>

Question

public void execute(Runnable command) ThreadPoolExecutor内からこのコマンドオブジェクトは、提出されたオブジェクトが含まれていますが、ラップされているようです。

カスタムスレッドプールエグゼキュータ内から送信されたオブジェクトにアクセスするにはどうすればよいですか？あるいは、ThreadPoolExecutorのbefore/after/executeメソッドの中から、送信されたオブジェクトにアクセスしようとするのは良い考えではありませんか？

Answer 1

executeを使用しないでください。submitを使用してください。これは、タスクのハンドルであるFutureを返します。あなたが直接タスクにアクセスすることはできませんが

ExecutorService service = Executors.newCachedThreadPool(); 

Callable<String> task = new Callable<String>() { 
    public String call() throws Exception { 
     return "hello world"; 
    } 
}; 

Future<String> future = service.submit(task); 

、あなたはまだそれと対話することができます：ここではいくつかのサンプルコードです

future.cancel(); // Won't start task if not already started 
String result = future.get(); // blocks until thread has finished calling task.call() and returns result 
future.isDone(); // true if complete 

ます。また、サービスと対話することができます

service.shutdown(); //etc  

コメントに組み込まれました：

あなたがうまくいけばtは、いくつかのロギングを行うには、次のように、afterExecute()メソッドをオーバーライドするanonymous classを使用します。

ThreadPoolExecutor executor = new ThreadPoolExecutor(1, 1, 1, TimeUnit.SECONDS, new ArrayBlockingQueue<Runnable>(1)) { 
     @Override 
     protected void afterExecute(Runnable r, Throwable t) 
     { 
      // Do some logging here 
      super.afterExecute(r, t); 
     } 
    }; 

オーバーライド他の方法、必要に応じ。

クイックプラグ：IMHO、この件に関する聖書はJava Concurrency in Practiceです。購入して読むことをお勧めします。