java Callable FutureTask Excecuter: Bitmiş görevi nasıl dinlerim

Question

Yönetici hizmetlerim için oldukça yeni. Her şeyi kendim yapmayı sevdim ama bence bu hizmetlere güvenmenin zamanı geldi.

Executer numaralı telefonu Runnable numarasına vermek istiyorum. Yürütücü bunu FutureTask'da tamamlar ve bana geri gönderir. Şimdi, done() yöntemini çağırıyorum. Ancak o zaman done() yönteminin doğru döndüğü zaman bildirim almak istiyorum.

Runnable tamamlanana kadar bloklayan bir get() yöntemi var, ancak bittiğinde görmek için her iş için fazladan bir iş parçacığına ihtiyacım var.

Görev bitirme hakkında bildirim almak için yöneticime biraz daha fazla Callable verebilir miyim?

Buraya gitmenin yolu nedir? Aynı iplik bunu yapmak için başka bir onun daha iyi ardına görevi yapmak istiyorsanız

Answer 1

Eğer, o zaman onun kanca yöntemleri kullanabilirsiniz bir java.util.concurrent.ThreadPoolExecutor kullanarak belirli bir varsayım yapabiliyorsanız; afterExecute() ve beforeExecute().

http://download.oracle.com/javase/6/docs/api/java/util/concurrent/ThreadPoolExecutor.html

Onlar ListenableFuture kadar zarif değildir, ancak o belirli bir infaz örneği için bir "dinleyici", sadece bir tür ihtiyaç sağlanan yeterli bir çözüm olabilir.

Answer 2

... Ben run yönteminin sonuna bazı kod eklemek, ama sonra done() hala yanlış olabilir.

Executor executor = 
final Runnable runnable = 
executor.execute(new Runnable() { 
    public void run() { 
     runnable.run(); 
     // do something after the run() has finished. 
    } 
}); 

aynı öbekte çalıştırılabilir sonra done istediğiniz ve yoklamak veya başka bir iş parçacığı kullanmak gerekmez her ne yapacağız Bu şekilde.

Answer 3

ben Guava içinde com.google.common.util.concurrent paketine bir göz, özellikle ListenableFuture türünü ve bununla ilgili kod alarak öneriyoruz ediyorum

http://download.oracle.com/javase/1.5.0/docs/api/java/util/concurrent/ExecutorCompletionService.html

Answer 4

ExecutorCompletionService.

Bir sonraki sürüm (r10) bittiğinde, MoreExecutors.listeningDecorator(ExecutorService) kullanarak ListenableFuture s döndüren bir ExecutorService oluşturmak kolay olacaktır. Şu anda Runnable s/Callable s ürününü kendiniz de ListenableFutureTask numaralı ürüne sarabilirsiniz.

final ListenableFutureTask<?> task = new ListenableFutureTask<Object>(
    runnable, null); 
executor.submit(task); 
task.addListener(new Runnable() { 
    public void run() { 
    // do whatever 
    } 
}, listenerExecutor);