任务完成时调用函数

Question

我正在开始执行器服务，我想知道当任务完成时如何调用函数。我见过这个函数http://docs.oracle.com/javase/8/docs/api/java/util/concurrent/Future.html#isDone--

但我不确定如何将其连接到我的代码中调用函数＜code＞endoftheroad（）

这是我的代码

//import java.util.concurrent.Callable;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
//import java.util.concurrent.Future;
//import java.util.concurrent.TimeUnit;
import java.util.*;

public class Pooler {

        public static int add(int x, int y){
        int c = x + y;
        return c;
        }
        public static int endoftheroad(){
        int the_end = 0;
        return the_end;
        }

    public static void main(String args[]) {
       ExecutorService service = Executors.newFixedThreadPool(10);
       for (int i =0; i<100; i++){
       Random randomno = new Random();
       int value = randomno.nextInt();
       service.submit(new Task(add(value,value)));
       }
    }

}


final class Task implements Runnable{
    private int taskId;

    public Task(int id){
        this.taskId = id;
    }

    @Override
    public void run() {
        System.out.println("Task ID : " + this.taskId +" performed by " 
                           + Thread.currentThread().getName());
    }

}

Answer 1

如果您的代码需要在Java7下运行，请查看Google的guava库中的ListenableFuture。如果您可以选择使用guava，ListenableFuture类可以准确地提供您需要的内容。https://code.google.com/p/guava-libraries/wiki/ListenableFutureExplained.有一个教程

如果你有Java 8，那么JDK的ComppletableFuture是另一种选择。

Answer 2

很简单，您当前的任务完成后会向执行程序提交一个新任务：

public void run() {
  doSomeStuff();
  executor.submit(new FinishHimTask());
}

但是，您应该记住，如果提交的任务是一个非常小的任务，那么在当前线程中执行它可能会更有性能，因为创建一个新任务并将其添加到执行器也需要一些时间。

Answer 3

您的成本有问题

a） 添加在当前线程中执行。除了在executors线程中执行打印外，什么都不做。

b）道路结束功能不做任何事情，因此是否调用它并不重要。

c)你忽略了未来的回报，使得使用它变得困难。

要回答你的问题，你可以在Java 8中使用CompleableFuture。然而，更简单的解决方案是:

• 将循环中的所有代码移动到run（）中
• 在run（）方法的末尾调用函数以在该代码之后运行